[ https://issues.apache.org/jira/browse/IGNITE-12252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nikolai Kulagin reassigned IGNITE-12252: ---------------------------------------- Assignee: Nikolai Kulagin (was: Anton Vinogradov) > Unchecked exceptions during rebalancing should be handled > --------------------------------------------------------- > > Key: IGNITE-12252 > URL: https://issues.apache.org/jira/browse/IGNITE-12252 > Project: Ignite > Issue Type: Bug > Reporter: Aleksey Plekhanov > Assignee: Nikolai Kulagin > Priority: Critical > Fix For: 2.8 > > > Rebalancing should handle unchecked exceptions by failure handler. In current > implementation unchecked exceptions just ignored. They were handled by IO > worker before IGNITE-3195. > Reproducer: > {code:java} > @Test > public void testRebalanceUncheckedError() throws Exception { > IgniteEx ignite0 = startGrid(new > IgniteConfiguration().setIgniteInstanceName("ignite0")); > IgniteCache<Integer, Integer> cache = > ignite0.getOrCreateCache(DEFAULT_CACHE_NAME); > IgniteDataStreamer<Integer, Integer> streamer = > ignite0.dataStreamer(DEFAULT_CACHE_NAME); > for (int i = 0; i < 100_000; i++) > streamer.addData(i, i); > streamer.flush(); > IgniteEx ignite1 = startGrid(new > IgniteConfiguration().setIgniteInstanceName("ignite1") > > .setIncludeEventTypes(EventType.EVT_CACHE_REBALANCE_OBJECT_LOADED)); > ignite1.events().localListen(e -> { > throw new Error(); > }, EventType.EVT_CACHE_REBALANCE_OBJECT_LOADED); > awaitPartitionMapExchange(); > } > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)