ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anton Vinogradov (Jira)" <j...@apache.org>
Subject [jira] [Commented] (IGNITE-12252) Unchecked exceptions during rebalancing should be handled
Date Wed, 16 Oct 2019 08:01:00 GMT

    [ https://issues.apache.org/jira/browse/IGNITE-12252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952591#comment-16952591
] 

Anton Vinogradov commented on IGNITE-12252:
-------------------------------------------

[~alex_pl], just a foolproof proposal ;) ++

Ok, let's keep semantic.

 

[~zzzadruga], seems we just have to provide proper catch instead of handlers improvements.

> 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
>
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> 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)

Mime
View raw message