[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
likang updated FLINK-16482:
---------------------------
Summary: Flink Job throw CloseException when call the FlinkKafkaConsumer
cancel function (was: Flink任务的kafkaSource因为cancel导致任务失败而重启)
> Flink Job throw CloseException when call the FlinkKafkaConsumer cancel
> function
> -------------------------------------------------------------------------------
>
> Key: FLINK-16482
> URL: https://issues.apache.org/jira/browse/FLINK-16482
> Project: Flink
> Issue Type: Bug
> Reporter: likang
> Priority: Critical
>
> Flink-kafka-Consumer
> 在用户程序调用cancel函数主动结束任务时,KafkaConsumerThread会抛出CloseException的异常，导致任务重启而不是正常退出
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
