[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16913408#comment-16913408
]
Randall Hauch commented on KAFKA-8391:
--------------------------------------
I've spent quite a bit of time on trying to discover the root cause, with no
luck so far. I have been able to reproduce it locally by running {{./gradlew
connect:runtime:clean connect:runtime:test --tests
org.apache.kafka.connect.integration.RebalanceSourceConnectorsIntegrationTest}}
100 times; the {{testReconfigConnector}} test failed 28% of the time and the
others failed 0%. This issue and KAFKA-8661 suggest that
{{testDeleteConnector}} and {{testStartTwoConnectors}} are also flaky, though
I've not seen those tests fail locally.
Because this flakiness is causing issues for the rest of the project, I'm going
to temporarily ignore several of the flaky ITs while I continue to investigate:
* {{RebalanceSourceConnectorsIntegrationTest.testReconfigConnector}}
* {{RebalanceSourceConnectorsIntegrationTest.testDeleteConnector}}
* {{RebalanceSourceConnectorsIntegrationTest.testStartTwoConnectors}}
See https://github.com/apache/kafka/pull/7237. *That PR should not resolve this
issue!*
> Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector
> -----------------------------------------------------------------------
>
> Key: KAFKA-8391
> URL: https://issues.apache.org/jira/browse/KAFKA-8391
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 2.3.0
> Reporter: Matthias J. Sax
> Assignee: Randall Hauch
> Priority: Critical
> Labels: flaky-test
> Fix For: 2.1.2, 2.2.2, 2.4.0, 2.3.1
>
>
> [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/4747/testReport/junit/org.apache.kafka.connect.integration/RebalanceSourceConnectorsIntegrationTest/testDeleteConnector/]
> {quote}java.lang.AssertionError: Condition not met within timeout 30000.
> Connector tasks did not stop in time. at
> org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:375) at
> org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:352) at
> org.apache.kafka.connect.integration.RebalanceSourceConnectorsIntegrationTest.testDeleteConnector(RebalanceSourceConnectorsIntegrationTest.java:166){quote}
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
