[jira] [Created] (FLINK-13124) Stop fails with Universal Kafka Consumer

[Shang Yuanchun (Jira)]

Konstantin Knauf created FLINK-13124:
----------------------------------------

             Summary: Stop fails with Universal Kafka Consumer
                 Key: FLINK-13124
                 URL: https://issues.apache.org/jira/browse/FLINK-13124
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Kafka
    Affects Versions: 1.9.0
            Reporter: Konstantin Knauf


When running the {{StateMachineExample}} (with the universal Kafka connector instead of 0.10) the Job always crashes with the following exception, when stopping it with {{flink stop <job-id>}}.

{noformat}
2019-07-05 13:16:49,809 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (1/1) (1a22bba845872431e8695fc8f3793fcd) switched from RUNNING to FAILED.
java.lang.Exception: org.apache.flink.streaming.connectors.kafka.internal.Handover$ClosedException
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.checkThrowSourceExecutionException(SourceStreamTask.java:194)
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.performDefaultAction(SourceStreamTask.java:121)
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.StreamTask.run(StreamTask.java:268)
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:376)
taskmanager_1  | at org.apache.flink.runtime.taskmanager.Task.run(Task.java:675)
taskmanager_1  | at java.lang.Thread.run(Thread.java:748)
taskmanager_1  | Caused by: org.apache.flink.streaming.connectors.kafka.internal.Handover$ClosedException
taskmanager_1  | at org.apache.flink.streaming.connectors.kafka.internal.Handover.close(Handover.java:182)
taskmanager_1  | at org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher.cancel(KafkaFetcher.java:175)
taskmanager_1  | at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.cancel(FlinkKafkaConsumerBase.java:817)
taskmanager_1  | at org.apache.flink.streaming.api.operators.StreamSource.cancel(StreamSource.java:124)
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.cancelTask(SourceStreamTask.java:144)
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.finishTask(SourceStreamTask.java:150)
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:781)
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpoint(StreamTask.java:656)
taskmanager_1  | at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.triggerCheckpoint(SourceStreamTask.java:160)
taskmanager_1  | at org.apache.flink.runtime.taskmanager.Task$1.run(Task.java:1120)
taskmanager_1  | at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1626)
taskmanager_1  | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
taskmanager_1  | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
taskmanager_1  | ... 1 more
{noformat}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)