Got it. Thanks a lot. This is very useful
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Since there are several approaches on solving this, I’m continue with your
code, a couple of suggestions:
- Create streamer instance out of loop, and close it on finally, not within the
loop.
- stmr.autoflushfrequency(0) as you do it every 2000 elements…
- Don’t forget remaining data (< 2000) f
Hi
Implemented the code as suggested by you. Please find the code related to
this. Please let me know is this
right way of implementing what you suggested.
Also can you please let me know the use of stmr.autoflushfrequency(2000)
method usage .If i pass higher number to this method,will that imp
> May 17, 2020 1:35:29 PM org.apache.ignite.logger.java.JavaLogger error
> SEVERE: DataStreamer operation failed.
> class org.apache.ignite.IgniteCheckedException: Data streamer has been
> cancelled: DataStreamerImpl [bufLdrSzPerThread=4096,
> rcvr=org.apache.ignite.internal.processors.datastreamer.D
cacheObjCtx=o.a.i.i.processors.cache.binary.CacheObjectBinaryContext@4a3be6a5,
cancelled=true, cancellationReason=class o.a.i.IgniteCheckedException: Data
streamer has been cancelled: DataStreamerImpl [bufLdrSzPerThread=4096,
rcvr=o.a.i.i.processors.datastreamer.DataStreamerImpl$IsolatedUpdater@3b0ee03a
