Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
Date: Thu, 10 Mar 2016 20:32:40 +0000 (UTC)
From: "Stephan Ewen (JIRA)" <jira@apache.org>
To: issues@flink.apache.org
Message-ID: <JIRA.12948374.1457521627000.62166.1457641960738@Atlassian.JIRA>
In-Reply-To: <JIRA.12948374.1457521627000@Atlassian.JIRA>
References: <JIRA.12948374.1457521627000@Atlassian.JIRA>
 <JIRA.12948374.1457521627557@arcas>
Subject: [jira] [Assigned] (FLINK-3594) StreamTask may fail when checkpoint
 is concurrent to regular termination
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


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

Stephan Ewen reassigned FLINK-3594:
-----------------------------------

    Assignee: Stephan Ewen

> StreamTask may fail when checkpoint is concurrent to regular termination
> ------------------------------------------------------------------------
>
>                 Key: FLINK-3594
>                 URL: https://issues.apache.org/jira/browse/FLINK-3594
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Chesnay Schepler
>            Assignee: Stephan Ewen
>              Labels: test-stability
>
> Some tests in the KafkaConsumerTestBase rely on throwing a SuccessException to stop the streaming job if the test condition is fulfilled.
> The job then fails, and it is checked whether the cause was a SuccessException. if so, the test is marked as a success, otherwise as a failure.
> However, should this exception be thrown while a checkpoint is being triggered, the exception that stop the job is not the SuccessException, but a CancelTaskException.
> This should affect every test that uses the SuccessException.
> observed here: https://travis-ci.org/apache/flink/jobs/114523189
> The problem is that the exception causes the StreamTask to enter the finally block inside invoke(), which sets isRunning to false. Within triggerCheckpoint() isRunning is then checked for being false, and if so a CancelTaskException is thrown.
> This seems like an issue of the runtime; i observed other tests failing, without giving a good cause since the CancelTaskException masks it.
> I was wondering whether triggerCheckpoint() could return false instead of throwing an exception, and simply assume that an exception will be thrown within invoke().


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