The GitHub Actions job "Flink Connector Kafka CI" on 
flink-connector-kafka.git/FLINK-37611-fix-it has failed.
Run started by GitHub user AHeise (triggered by AHeise).

Head commit for run:
9c8df3a589a131a1dfff442f075ac69c44855374 / Arvid Heise <ar...@apache.org>
[FLINK-37611] Deflake 
ExactlyOnceKafkaWriterITCase#shouldAbortLingeringTransactions

The test was actually not working correctly since writer's get their unique 
prefix (pool rework PR). The test mostly succeeded since the partitions in 
which records were written was non-deterministic and more often than not the 3 
records didn't meet in the 10 partitions which resulted in an incorrect pass.

Now the value is also passed as a key, which makes partitions assignment 
deterministic and for this test we just write the exact same value 3 times.

Report URL: 
https://github.com/apache/flink-connector-kafka/actions/runs/14260441544

With regards,
GitHub Actions via GitBox

Reply via email to