pnowojski commented on a change in pull request #9912:
[FLINK-14370][kafka][test-stability] Fix the cascading failure in
kaProducerTestBase.
URL: https://github.com/apache/flink/pull/9912#discussion_r338071221
##########
File path:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java
##########
@@ -283,9 +283,7 @@ public int partition(Integer record, byte[] key, byte[]
value, String targetTopi
try {
env.execute("One-to-one at least once test");
- // The following failure message is added to debug the
case why the job did not fail as expected.
- fail(String.format("Job should fail! Last successfully
checkpointed message : %d",
Review comment:
Could you explain why are you removing this? Maybe add an explanation in the
commit message?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
