[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289928#comment-17289928
]
Dong Lin commented on FLINK-21214:
----------------------------------
Given that this test has the same error message as
FlinkKafkaProducerITCase.testRecoverCommittedTransaction described in
FLINK-18634 [1], and that both tests uses transaction uses transaction, it is
very likely that this test failure is due to bug described in [2].
The solution is to bump up Kafka dependency to 2.5.1. However, Kafka 2.5.1 has
dropped support for Scala 2.11. Flink will also need to drop support for Scala
2.11 in order to bump up the Kafka dependency to 2.5.1. This appears to be a
big deal for the Flink community. I will leave to to more experienced Flink
developers to drive this effort.
[1] https://issues.apache.org/jira/browse/FLINK-18634
[2]
https://issues.apache.org/jira/browse/FLINK-18634?focusedCommentId=17284445&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-17284445
> FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed
> ------------------------------------------------------------------
>
> Key: FLINK-21214
> URL: https://issues.apache.org/jira/browse/FLINK-21214
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.11.0, 1.12.0
> Reporter: Guowei Ma
> Priority: Major
> Labels: test-stability
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=12687&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=1fb1a56f-e8b5-5a82-00a0-a2db7757b4f5]
>
> [ERROR]
> testScaleDownBeforeFirstCheckpoint(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
> Time elapsed: 62.857 s <<< ERROR!
> org.apache.kafka.common.errors.TimeoutException:
> org.apache.kafka.common.errors.TimeoutException: Timeout expired after
> 60000milliseconds while awaiting InitProducerId
> Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout expired
> after 60000milliseconds while awaiting InitProducerId
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
