ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Denis Mekhanikov <dmekhani...@gmail.com>
Subject Re: ClusterTopologyCheckedException: Failed to wait for request completion (node has left) while loading data into using savePairs method of Ignite Red
Date Tue, 26 Sep 2017 08:46:19 GMT
Hi!

This exception is usually thrown when topology changes during execution of
some operation.
Did you see messages in logs that this node with id from the exception
failed or left?

Denis

вт, 26 сент. 2017 г. в 3:48, pradeepchanumolu <pradeepbaji@gmail.com>:

> I am using savePairs method of the IgniteRdd with overwrite set to true.
> I am hitting the following exception when the loading of data from HDFS to
> Ignite is happening.
>
> Here is the snippet of code:
>
>     val igniteRDD = igniteContext.fromCache(cacheCfg)
>     igniteRDD.savePairs(inputRdd, overwrite = true)
>
>
> Exception:
>
> at
>
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:865)
>         at
>
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$5.apply(DataStreamerImpl.java:834)
>         at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:382)
>         at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.unblock(GridFutureAdapter.java:346)
>         at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.unblockAll(GridFutureAdapter.java:334)
>         at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:494)
>         at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:473)
>         at
>
> org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:461)
>         at
>
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.onNodeLeft(DataStreamerImpl.java:1748)
>         at
>
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$2$1.run(DataStreamerImpl.java:309)
>         at
>
> org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(IgniteUtils.java:6664)
>         at
>
> org.apache.ignite.internal.processors.closure.GridClosureProcessor$1.body(GridClosureProcessor.java:817)
>         at
> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110)
>         ... 3 more
> Caused by: class
> org.apache.ignite.internal.cluster.ClusterTopologyCheckedException: Failed
> to wait for request completion (node has left):
> 0b6e3193-6075-417a-9038-70a66ca3ac86
>         at
>
> org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl$Buffer.onNodeLeft(DataStreamerImpl.java:1744)
>         ... 7 more
>
>
> Can someone help me with the above error?
>
> I also increased the failure detection timeout in the IgniteConfiguration
> by
> doing
>
> conf.setClientFailureDetectionTimeout(Long.MaxValue)
>
>
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>

Mime
View raw message