[FLINK-26321] KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Duplicate
• Affects Version/s: 1.15.0
• Component/s: Connectors / Kafka
• Labels: test-stability
• Assignee: Alexander Preuss
• Reporter: Matthias Pohl
• Created: 23/Feb/22 07:43
• Updated: 04/Mar/22 09:13
• Resolved: 04/Mar/22 09:13

Description

This build failed due to a test failure in KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee:

Feb 22 21:55:15 [ERROR] Tests run: 8, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 65.897 s <<< FAILURE! - in org.apache.flink.connector.kafka.sink.KafkaSinkITCase
Feb 22 21:55:15 [ERROR] org.apache.flink.connector.kafka.sink.KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee  Time elapsed: 25.251 s  <<< FAILURE!
Feb 22 21:55:15 java.lang.AssertionError: expected:<20912> but was:<20913>
Feb 22 21:55:15 	at org.junit.Assert.fail(Assert.java:89)
Feb 22 21:55:15 	at org.junit.Assert.failNotEquals(Assert.java:835)
Feb 22 21:55:15 	at org.junit.Assert.assertEquals(Assert.java:647)
Feb 22 21:55:15 	at org.junit.Assert.assertEquals(Assert.java:633)
Feb 22 21:55:15 	at org.apache.flink.connector.kafka.sink.KafkaSinkITCase.writeRecordsToKafka(KafkaSinkITCase.java:424)
Feb 22 21:55:15 	at org.apache.flink.connector.kafka.sink.KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee(KafkaSinkITCase.java:231)
[...]

Issue Links

• is caused by: FLINK-26403 SinkWriter should emit all the pending committables on endOfInput
• is superceded by: FLINK-26403 SinkWriter should emit all the pending committables on endOfInput