flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling
Date Thu, 26 Nov 2015 13:27:11 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15028781#comment-15028781

ASF GitHub Bot commented on FLINK-3081:

GitHub user rmetzger opened a pull request:


    [FLINK-3081] Properly stop periodic Kafka committer


You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/rmetzger/flink flink3081

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #1410
commit 70373b381fbcb5afc3a56f8610766cfe31eb963f
Author: Robert Metzger <rmetzger@apache.org>
Date:   2015-11-26T13:25:54Z

    [FLINK-3081] Properly stop periodic Kafka committer


> Kafka Periodic Offset Committer does not properly terminate on canceling
> ------------------------------------------------------------------------
>                 Key: FLINK-3081
>                 URL: https://issues.apache.org/jira/browse/FLINK-3081
>             Project: Flink
>          Issue Type: Bug
>          Components: Kafka Connector
>    Affects Versions: 0.10.1
>            Reporter: Stephan Ewen
>            Assignee: Robert Metzger
>            Priority: Blocker
>             Fix For: 1.0.0, 0.10.2
> The committer is only stopped at the end of the run method. Any termination of the run
method via an exception keeps the periodic committer thread running.

This message was sent by Atlassian JIRA

View raw message