flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-3594) StreamTask may fail when checkpoint is concurrent to regular termination
Date Wed, 12 Oct 2016 17:50:20 GMT

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

Stephan Ewen closed FLINK-3594.

> 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
>            Priority: Critical
>              Labels: test-stability
>             Fix For: 1.1.0
> 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

View raw message