[
https://issues.apache.org/jira/browse/FLINK-11072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022738#comment-17022738
]
Jiangjie Qin commented on FLINK-11072:
--------------------------------------
[~gjy] To avoid confusion, should we create a new Jira ticket if the failure
cause was different from the original one, which is admin client closing
timeout.
One possible cause of this failure might be that the idempotent producer was
not enabled, so duplicate messages may be produced on retries. I'll fix that
first.
> KafkaITCase.testKeyValueSupport failure
> ---------------------------------------
>
> Key: FLINK-11072
> URL: https://issues.apache.org/jira/browse/FLINK-11072
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.7.0, 1.10.0
> Reporter: Bowen Li
> Assignee: Jiangjie Qin
> Priority: Critical
> Labels: test-stability
> Fix For: 1.10.0
>
>
> https://api.travis-ci.org/v3/job/463479076/log.txt
> {code:java}
> Results :
> Tests in error:
>
> KafkaITCase.testKeyValueSupport:78->KafkaConsumerTestBase.runKeyValueTest:1447->KafkaTestBase.deleteTestTopic:206->Object.wait:502->Object.wait:-2
> » TestTimedOut
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
