[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482200#comment-17482200 ]
Yun Gao commented on FLINK-16908: --------------------------------- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=30089&view=logs&j=72d4811f-9f0d-5fd0-014a-0bc26b72b642&t=e424005a-b16e-540f-196d-da062cc19bdf&l=7120 > FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while > initializing transactional state in 60000ms. > ----------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-16908 > URL: https://issues.apache.org/jira/browse/FLINK-16908 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: 1.11.0, 1.12.0, 1.13.2, 1.14.3 > Reporter: Piotr Nowojski > Assignee: Fabian Paul > Priority: Minor > Labels: auto-deprioritized-major, test-stability > Fix For: 1.15.0 > > > https://dev.azure.com/rmetzger/Flink/_build/results?buildId=6889&view=logs&j=c5f0071e-1851-543e-9a45-9ac140befc32&t=f66652e3-384e-5b25-be29-abfea69ea8da > {noformat} > [ERROR] > testScaleUpAfterScalingDown(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase) > Time elapsed: 64.353 s <<< ERROR! > org.apache.kafka.common.errors.TimeoutException: Timeout expired while > initializing transactional state in 60000ms. > {noformat} > After this initial error many other tests (I think all following unit tests) > failed with errors like: > {noformat} > [ERROR] > testFailAndRecoverSameCheckpointTwice(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase) > Time elapsed: 7.895 s <<< FAILURE! > java.lang.AssertionError: Detected producer leak. Thread name: > kafka-producer-network-thread | producer-196 > at > org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.checkProducerLeak(FlinkKafkaProducerITCase.java:675) > at > org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice(FlinkKafkaProducerITCase.java:311) > {noformat} -- This message was sent by Atlassian Jira (v8.20.1#820001)