[jira] [Created] (FLINK-24972) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout due to failed to complete checkpoint

[Yun Gao (Jira)]

Yun Gao created FLINK-24972:
-------------------------------

             Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown 
Timeout due to failed to complete checkpoint
                 Key: FLINK-24972
                 URL: https://issues.apache.org/jira/browse/FLINK-24972
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.14.0
            Reporter: Yun Gao


{code:java}
Nov 20 23:38:33 [ERROR] Tests run: 15, Failures: 10, Errors: 1, Skipped: 0, 
Time elapsed: 270.661 s <<< FAILURE! - in 
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase
Nov 20 23:38:33 [ERROR] testScaleUpAfterScalingDown  Time elapsed: 64.049 s  
<<< ERROR!
Nov 20 23:38:33 org.apache.flink.runtime.checkpoint.CheckpointException: Could 
not complete snapshot 1 for operator MockTask (2/4)#0. Failure reason: 
Checkpoint was declined.
Nov 20 23:38:33         at 
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:265)
 {code}
After this failure the other tests failed with 
{code:java}
Nov 20 23:38:33 
Nov 20 23:38:33 [ERROR] testFailAndRecoverSameCheckpointTwice  Time elapsed: 
5.697 s  <<< FAILURE!
Nov 20 23:38:33 java.lang.AssertionError: Detected producer leak. Thread name: 
kafka-producer-network-thread | 
producer-MockTask-000000000000002a000000000000002c-5
Nov 20 23:38:33         at org.junit.Assert.fail(Assert.java:89) {code}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)