Hi, I have Ignite (version 1.7.0) setup to do streaming, and a autoFlushFrequency of 15 (for now) - in the logs, I'm getting this during processing - any ideas on what this is coming from?
2016-09-13T17:31:52,580 - ERROR [grid-data-loader-flusher-#55%null%:Slf4jLogger@112] - Runtime error caught during grid runnable execution: GridWorker [name=grid-data-loader-flusher, gridName=null, finished=false, isCancelled=false, hashCode=1315116657, interrupted=false, runner=grid-data-loader-flusher-#55%null%] org.apache.ignite.binary.BinaryObjectException: Failed to marshal object with optimized marshaller: org.apache.ignite.stream.StreamVisitor$1@4e8b328a at org.apache.ignite.internal.binary.BinaryWriterExImpl.marshal(BinaryWriterExImpl.java:167) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.binary.BinaryWriterExImpl.marshal(BinaryWriterExImpl.java:132) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.binary.GridBinaryMarshaller.marshal(GridBinaryMarshaller.java:239) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.binary.BinaryMarshaller.marshal(BinaryMarshaller.java:92) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.submit(DataStreamerImpl.java:1362) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.flush(DataStreamerImpl.java:1248) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.tryFlush(DataStreamerImpl.java:970) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor$2.body(DataStreamProcessor.java:108) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) [ignite-core-1.7.0.jar:1.7.0] at java.lang.Thread.run(Thread.java:745) [?:1.8.0_31] Caused by: org.apache.ignite.IgniteCheckedException: Failed to serialize object: org.apache.ignite.stream.StreamVisitor$1@4e8b328a at org.apache.ignite.marshaller.optimized.OptimizedMarshaller.marshal(OptimizedMarshaller.java:197) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.binary.BinaryWriterExImpl.marshal(BinaryWriterExImpl.java:160) ~[ignite-core-1.7.0.jar:1.7.0] ... 9 more Caused by: java.io.IOException: java.util.ConcurrentModificationException at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:347) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeArray(OptimizedObjectOutputStream.java:267) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:698) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObjectOverride(OptimizedObjectOutputStream.java:161) ~[ignite-core-1.7.0.jar:1.7.0] at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:344) ~[?:1.8.0_31] at org.apache.ignite.marshaller.optimized.OptimizedMarshaller.marshal(OptimizedMarshaller.java:192) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.binary.BinaryWriterExImpl.marshal(BinaryWriterExImpl.java:160) ~[ignite-core-1.7.0.jar:1.7.0] ... 9 more Caused by: java.util.ConcurrentModificationException at java.util.LinkedList$ListItr.checkForComodification(LinkedList.java:966) ~[?:1.8.0_31] at java.util.LinkedList$ListItr.next(LinkedList.java:888) ~[?:1.8.0_31] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeLinkedList(OptimizedObjectOutputStream.java:418) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:733) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeArrayList(OptimizedObjectOutputStream.java:368) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:718) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObjectOverride(OptimizedObjectOutputStream.java:161) ~[ignite-core-1.7.0.jar:1.7.0] at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:344) ~[?:1.8.0_31] at java.util.concurrent.ConcurrentHashMap.writeObject(ConcurrentHashMap.java:1413) ~[?:1.8.0_31] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_31] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_31] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_31] at java.lang.reflect.Method.invoke(Method.java:483) ~[?:1.8.0_31] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:341) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeArray(OptimizedObjectOutputStream.java:267) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:698) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeFields(OptimizedObjectOutputStream.java:539) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeSerializable(OptimizedObjectOutputStream.java:351) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedClassDescriptor.write(OptimizedClassDescriptor.java:800) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObject0(OptimizedObjectOutputStream.java:247) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.marshaller.optimized.OptimizedObjectOutputStream.writeObjectOverride(OptimizedObjectOutputStream.java:161) ~[ignite-core-1.7.0.jar:1.7.0] at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:344) ~[?:1.8.0_31] at org.apache.ignite.marshaller.optimized.OptimizedMarshaller.marshal(OptimizedMarshaller.java:192) ~[ignite-core-1.7.0.jar:1.7.0] at org.apache.ignite.internal.binary.BinaryWriterExImpl.marshal(BinaryWriterExImpl.java:160) ~[ignite-core-1.7.0.jar:1.7.0] ... 9 more -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Data-Streamer-error-tp7725.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.