Hello! Does it work with a smaller batch? My guess is that you end up consuming too much resources and then the cluster falls apart.
Regards, -- Ilya Kasnacheev сб, 6 мар. 2021 г. в 00:59, Josh Katz <josh.katz.contrac...@dodgeandcox.com >: > Client node gets disconnected while trying to load data to cache using a > data streamer… > > > > How can we overcome this issue and load data to cache reliably? > > > > See Exception call stack: > > > > Apache.Ignite.Core.Common.ClientDisconnectedException: Client node > disconnected: ignite-instance-dab0a266-a4fb-403f-863c-289d3ed18ab7 ---> > Apache.Ignite.Core.Common.JavaException: class > org.apache.ignite.IgniteClientDisconnectedException: Client node > disconnected: ignite-instance-dab0a266-a4fb-403f-863c-289d3ed18ab7 at > org.apache.ignite.internal.GridKernalGatewayImpl.readLock(GridKernalGatewayImpl.java:93) > at > org.apache.ignite.internal.cluster.ClusterGroupAdapter.guard(ClusterGroupAdapter.java:175) > at > org.apache.ignite.internal.cluster.ClusterGroupAdapter.forPredicate(ClusterGroupAdapter.java:379) > at > org.apache.ignite.internal.cluster.ClusterGroupAdapter.forCacheNodes(ClusterGroupAdapter.java:593) > at > org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.allowOverwrite(DataStreamerImpl.java:496) > at > org.apache.ignite.internal.processors.platform.datastreamer.PlatformDataStreamer.processInLongOutLong(PlatformDataStreamer.java:187) > at > org.apache.ignite.internal.processors.platform.PlatformTargetProxyImpl.inLongOutLong(PlatformTargetProxyImpl.java:55) > at Apache.Ignite.Core.Impl.Unmanaged.Jni.Env.ExceptionCheck() at > Apache.Ignite.Core.Impl.Unmanaged.Jni.Env.CallLongMethod(GlobalRef obj, > IntPtr methodId, Int64* argsPtr) at > Apache.Ignite.Core.Impl.Unmanaged.UnmanagedUtils.TargetInLongOutLong(GlobalRef > target, Int32 opType, Int64 memPtr) at > Apache.Ignite.Core.Impl.PlatformJniTarget.InLongOutLong(Int32 type, Int64 > val) --- End of inner exception stack trace --- at > Apache.Ignite.Core.Impl.PlatformJniTarget.InLongOutLong(Int32 type, Int64 > val) at > Apache.Ignite.Core.Impl.Datastream.DataStreamerImpl`2.set_AllowOverwrite(Boolean > value) at PopulateCache(String accountStyle, DateTime startDate, > DateTime endDate) > > > > Thanks, > > Josh Katz > ------------------------------ > Please follow the hyperlink to important disclosures. > https://www.dodgeandcox.com/disclosures/email_disclosure_funds.html > >
