Mailing-List: contact issues-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@ignite.apache.org
Date: Tue, 15 Nov 2016 19:41:58 +0000 (UTC)
From: "Saikat Maitra (JIRA)" <jira@apache.org>
To: issues@ignite.apache.org
Message-ID: <JIRA.13014383.1477077901000.284041.1479238918490@Atlassian.JIRA>
In-Reply-To: <JIRA.13014383.1477077901000@Atlassian.JIRA>
References: <JIRA.13014383.1477077901000@Atlassian.JIRA> <JIRA.13014383.1477077901423@arcas>
Subject: [jira] [Commented] (IGNITE-4103) IgniteDataStreamer doesn't throw
 exception if cache is destroyed
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Tue, 15 Nov 2016 19:42:00 -0000


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

Saikat Maitra commented on IGNITE-4103:
---------------------------------------

[~avinogradov]

Hi Anton,

I verified that in DataStreamProcessor #localUpdate() the check is present for cache but it is not present in IgniteCacheObjectProcessorImpl #partition() method.

Can you please rethrow the IgniteCheckedException in the above partition() method. 

Regards,
Saikat

> IgniteDataStreamer doesn't throw exception if cache is destroyed
> ----------------------------------------------------------------
>
>                 Key: IGNITE-4103
>                 URL: https://issues.apache.org/jira/browse/IGNITE-4103
>             Project: Ignite
>          Issue Type: Bug
>          Components: cache
>    Affects Versions: 1.7
>            Reporter: Valentin Kulichenko
>            Assignee: Saikat Maitra
>             Fix For: 1.8
>
>         Attachments: StreamerTest.java
>
>
> Test reproducing the issue is attached.
> When a streamer streams the data and someone concurrently destroys the cache, {{addData}} doesn't throw an exception. Code continues to work and a lot of messages like this appear in the log:
> {noformat}
> [12:20:38,451][ERROR][main][CacheObjectBinaryProcessorImpl] Failed to get partition
> {noformat}
> The problematic code is in {{IgniteCacheObjectProcessorImpl.partition(...)}} method:
> {code}
> try {
>     return cctx != null ?
>         cctx.affinity().partition(obj, false) :
>         ctx.kernalContext().affinity().partition0(ctx.cacheName(), obj, null);
> }
> catch (IgniteCheckedException e) {
>     U.error(log, "Failed to get partition");
>     return  -1;
> }
> {code}
> There are two issues here:
> # Exception is completely ignored, it's not even printed out in {{U.error}}.
> # The exception should be actually rethrown so that streamer can stop adding data.


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)