You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/11/30 13:52:00 UTC
[jira] [Created] (FLINK-11042)
testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is an invalid
test
Piotr Nowojski created FLINK-11042:
--------------------------------------
Summary: testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is an invalid test
Key: FLINK-11042
URL: https://issues.apache.org/jira/browse/FLINK-11042
Project: Flink
Issue Type: Bug
Components: Kinesis Connector
Affects Versions: 1.8.0
Reporter: Piotr Nowojski
Assignee: Piotr Nowojski
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)