You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2021/09/29 05:12:00 UTC

[jira] [Commented] (KAFKA-10812) Unclean worker shutdown in MirrorConnectorsIntegrationTest

    [ https://issues.apache.org/jira/browse/KAFKA-10812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17421931#comment-17421931 ] 

Matthias J. Sax commented on KAFKA-10812:
-----------------------------------------

Failed again:
{quote}org.opentest4j.AssertionFailedError: Condition not met within timeout 30000. Unable to find checkpoints for primary.test-topic-1 ==> expected: <true> but was: <false> at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55) at org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:40) at org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:193) at org.apache.kafka.test.TestUtils.lambda$waitForCondition$3(TestUtils.java:320) at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:368) at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:317) at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:301) at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:291) at org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.testOffsetSyncsTopicsOnTarget(MirrorConnectorsIntegrationBaseTest.java:503){quote}

> Unclean worker shutdown in MirrorConnectorsIntegrationTest
> ----------------------------------------------------------
>
>                 Key: KAFKA-10812
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10812
>             Project: Kafka
>          Issue Type: Bug
>          Components: KafkaConnect, mirrormaker
>    Affects Versions: 2.7.0
>            Reporter: Chris Egerton
>            Priority: Major
>
> Although the flakiness for the {{MirrorConnectorsIntegrationTest}} has (hopefully) been addressed by https://github.com/apache/kafka/pull/9698, the root cause (unclean worker shutdown during those tests) has still not been addressed. This suggests that users of MirrorMaker 2 will see {{ERROR}} -level stack traces when shutting down workers running MM2 (https://github.com/apache/kafka/blob/a57486e75084d70f1fbf22df9d3ffc3462302add/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java#L301-L304), which looks fairly alarming, and may even indicate some problems with the functioning of MM2 itself.
> It'd be nice to diagnose the root cause of these unclean worker shutdowns when running MM2 during these tests and address them via improvements to the test cases, improvements to MM2 itself, or both.



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