[
https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053951#comment-17053951
]
Hequn Cheng commented on FLINK-16482:
-------------------------------------
[~kangzai] Hi, thanks a lot for reporting the bug! Could you translate the
title and description from Chinese to English? It would be great if you can
also provide some exception stack and even provide some code to reproduce the
bug which may be quite helpful for others to investigate the problem.
There is a contribution guide
[here|https://flink.apache.org/contributing/how-to-contribute.html]. Hope it
helps.
> Flink任务的kafkaSource因为cancel导致任务失败而重启
> ------------------------------------
>
> 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)
