What is the value IgniteDataStreamer#allowOverwrite(boolean)? The property changes of algorithm of work DataStreamer, in particular order of remap node. Try to set it true.
On Wed, Apr 19, 2017 at 7:29 PM, rishi007bansod <[email protected]> wrote: > Hi Below is our architecture, > > 1. Ignite receives data via Kafka Streamer > 2. Tuple Extractor is implemented in ignite code > Everything works fine till this step. > 3. We stop kafka. No error yet. > 4. We kill 2 instance (out of n instance) of ignite. > 5. Kafka Consumer remapping also happens without any issue. > 6. Cache rebalancing also seems completed (via log) > 6. Post 2 mins, kafka is again started. > And then we get the below error > class org.apache.ignite.IgniteCheckedException: Failed to finish operation > (too many remaps): 32 > > Even after Cache rebalancing and consumer mapping seems completed and when > ignite receives new data through kafka then only error is coming. > So not able to understand what remap ignite is doing? > > One point just for info, we are using Data streamer to add data in one > cache > and ignite visitor to process data. > All caches are partitioned and have backup set to 1. > > > > -- > View this message in context: http://apache-ignite-users. > 70518.x6.nabble.com/what-does-remaps-mean-in-DataStreamerImpl-java- > tp12033p12085.html > Sent from the Apache Ignite Users mailing list archive at Nabble.com. > -- Vladislav Pyatkov
