[FLINK-11042] testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is an invalid test

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.8.0
• Component/s: Connectors / Kinesis
• Labels: pull-request-available
• Assignee: Piotr Nowojski
• Reporter: Piotr Nowojski
• Created: 30/Nov/18 13:51
• Updated: 04/Feb/19 12:17
• Resolved: 04/Feb/19 12:17

Description

main point of testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is to fail transaction coordinator (by using kafkaProducer.getTransactionCoordinatorId(); ) and we expect that this will cause failure of Flink job. However that's not always the case. Maybe because transaction coordinator can be re-elected before KafkaProducer even notices it or for whatever the reason, sometimes the failure is not happening.

Because of a bug in the test, if failure hasn't happened, the test will not fail.

Generally speaking this test is invalid and should be dropped.

Issue Links

• links to: GitHub Pull Request #7206