我需要写一个文件流到数据库。文件内容必须只能通过ObjectOutput流,因为它是java中的二进制写入机制。正在写入流ObjectOutputStream os = new ObjectOutputStreamHIIIIIIIIIIIIIIIIIIIIII HOW ARE YOU");¬í t #HI
我们运行了一个Google批处理作业,它将数据记录写入一个pubsub管道,并有一个单独的流作业,它使用“pubsub to elasticsearch”流模板从PubSub管道中提取数据,并将更新写入我们的但是,我们不得不终止写入Elastic的流作业,因为在1次尝试之后,我们遇到了多个“向ES写入错误”。再也不允许“错误”了。从PubSub读取并写入Elasticsearch的任务是写入不是流索引的索引。它实际上
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1361) at io.WrappingUnwrappingOrderingTest.main(WrappingUnwrappingOrderingTest.javaat java.io.ObjectInputS