[FLINK-18308] KafkaProducerTestBase->Kafka011ProducerExactlyOnceITCase. testExactlyOnceCustomOperator hangs in Azure

• Type: Bug
• Status: Closed
• Priority: Not a Priority
• Resolution: Not A Problem
• Affects Version/s: 1.11.0
• Component/s: Connectors / Kafka
• Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor test-stability
• Assignee: Unassigned
• Reporter: Andrey Zagrebin
• Created: 15/Jun/20 14:57
• Updated: 23/May/22 11:54
• Resolved: 23/May/22 11:54

Description

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=3267&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=03dca39c-73e8-5aaf-601d-328ae5c35f20

For last 3.5 hours, the test log ends with about 5000 entries like this:

2020-06-11T11:04:54.3299945Z 11:04:54,328 [FailingIdentityMapper Status Printer] INFO  org.apache.flink.streaming.connectors.kafka.testutils.FailingIdentityMapper [] - ============================> Failing mapper  0: count=690, totalCount=1000

The problem was observed not on master but in this PR. The PR is simple fatal error handling refactoring in TM. Therefore, the PR looks unrelated. Another run of this PR in My Azure CI passes.