[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311261#comment-17311261
]
Dong Lin edited comment on FLINK-21214 at 3/30/21, 8:18 AM:
------------------------------------------------------------
[~dwysakowicz] we have investigated this bug previously and the explanation is
provided in the comments above. This is due to a known issue in Kafka. The
solution is to bump up Kafka dependency to 2.5.1 or later.
However, we could not do it yet because Kafka 2.5.1 has dropped support for
Scala 2.11. We will need to first discuss whether we should update Flink to
drop support for Scala 2.11. The discussion of this topic is not specific to
Kafka. We have not started this discussion yet due to being busy with Flink
1.13 release.
According to the test history, this bug does not happy frequently. Does this
bug need the "critical" priority?
was (Author: lindong):
[~dwysakowicz] we have investigated this bug previously and the explanation is
provided in the comments above. This is due to a known issue in Kafka. The
solution is to bump up Kafka dependency to 2.5.1 or later.
However, we could not do it yet because Kafka 2.5.1 has dropped support for
Scala 2.11. We will need to first discuss whether we should update Flink to
drop support for Scala 2.11. The discussion of this topic is not specific to
Kafka. We have not started this discussion yet due to being busy with Flink
1.13 release.
According to the test history, this bug does not happy frequently. Does this
bug needs to "critical" priority?
> 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, 1.13.0
> Reporter: Guowei Ma
> Priority: Critical
> 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)
