[jira] [Created] (FLINK-18308) KafkaProducerTestBase->Kafka011ProducerExactlyOnceITCase. testExactlyOnceCustomOperator hangs in Azure

["Andrey Zagrebin (Jira)" <ji...@apache.org>]

Andrey Zagrebin created FLINK-18308:
---------------------------------------

             Summary: KafkaProducerTestBase->Kafka011ProducerExactlyOnceITCase. testExactlyOnceCustomOperator hangs in Azure
                 Key: FLINK-18308
                 URL: https://issues.apache.org/jira/browse/FLINK-18308
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.11.0
            Reporter: Andrey Zagrebin


[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:
{code:java}
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{code}
The problem was observed not on master but in [this PR|https://github.com/apache/flink/pull/12596]. 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|https://dev.azure.com/azagrebin/azagrebin/_build/results?buildId=214&view=results].



--
This message was sent by Atlassian Jira
(v8.3.4#803005)