ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Nikolai Kulagin (Jira)" <j...@apache.org>
Subject [jira] [Commented] (IGNITE-12252) Unchecked exceptions during rebalancing should be handled
Date Tue, 15 Oct 2019 11:25:00 GMT

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

Nikolai Kulagin commented on IGNITE-12252:
------------------------------------------

[~avinogradov],

I believe that other thread pools are not critical, it is worth handling exceptions the only
if it is OOM. Rebalance is a critical operation, and all exceptions must be handled by failure
handler.

> 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