[jira] [Updated] (IGNITE-12252) Unchecked exceptions during rebalancing should be handled

[Aleksey Plekhanov (Jira)]

     [ 
https://issues.apache.org/jira/browse/IGNITE-12252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aleksey Plekhanov updated IGNITE-12252:
---------------------------------------
    Description: 
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}


  was:Rebalancing should handle runtime exceptions by failure handler. In 
current implementation runtime exceptions just ignored. They were handled by IO 
worker before IGNITE-3195.


> 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: Anton Vinogradov
>            Priority: Blocker
>             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)