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 07:11:00 GMT

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

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

[~alex_pl], It looks like better case is to handle errors properly on workers' level, but
also extend oomeHnd to handle any unhandled errors?

Also, we may add an assertion that only OOME is suitable at oomeHnd?

> 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