[FLINK-7343] Kafka010ProducerITCase instability

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Component/s: Connectors / Kafka
• Labels: test-stability
• Assignee: Piotr Nowojski
• Reporter: Piotr Nowojski
• Created: 02/Aug/17 07:03
• Updated: 21/Mar/18 22:40
• Resolved: 21/Mar/18 22:40

Description

As reported by till.rohrmann in https://issues.apache.org/jira/browse/FLINK-6996 there seems to be a test instability with `Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink`

https://travis-ci.org/tillrohrmann/flink/jobs/258538641

It is probably related to log.flush intervals in Kafka, which delay flushing the data to files and potentially causing data loses on killing Kafka brokers in the tests.

Issue Links

• links to: GitHub Pull Request #4456
• links to: GitHub Pull Request #4470
• links to: GitHub Pull Request #5729