Yun Gao created FLINK-24970:
-------------------------------
Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown
Timeout expired after 60000 milliseconds while awaiting InitProducerId
Key: FLINK-24970
URL: https://issues.apache.org/jira/browse/FLINK-24970
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.15.0
Reporter: Yun Gao
{code:java}
Nov 20 23:27:52 [ERROR] Tests run: 15, Failures: 10, Errors: 1, Skipped: 0,
Time elapsed: 341.449 s <<< FAILURE! - in
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase
Nov 20 23:27:52 [ERROR] testScaleUpAfterScalingDown Time elapsed: 75.789 s
<<< ERROR!
Nov 20 23:27:52 org.apache.kafka.common.errors.TimeoutException: Timeout
expired after 60000 milliseconds while awaiting InitProducerId{code}
After that a lot of tests failed due to
{code:java}
Nov 20 23:27:52 [ERROR] testScaleUpAfterScalingDown Time elapsed: 75.789 s
<<< ERROR!
Nov 20 23:27:52 org.apache.kafka.common.errors.TimeoutException: Timeout
expired after 60000 milliseconds while awaiting InitProducerId
Nov 20 23:27:52
Nov 20 23:27:52 [ERROR] testFailAndRecoverSameCheckpointTwice Time elapsed:
10.031 s <<< FAILURE!
Nov 20 23:27:52 java.lang.AssertionError: Detected producer leak. Thread name:
kafka-producer-network-thread |
producer-MockTask-000000000000002a000000000000002c-9
Nov 20 23:27:52 at org.junit.Assert.fail(Assert.java:89) {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
