This is an automated email from the ASF dual-hosted git repository.
gwenshap pushed a commit to branch 2.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push:
new b99013c KAFKA-8391; Temporarily ignore flaky Connect rebalance
integration tests
b99013c is described below
commit b99013ca11df86e9d0527ca7bea1d386cb61378c
Author: Randall Hauch <rha...@gmail.com>
AuthorDate: Sun Aug 25 14:30:23 2019 -0700
KAFKA-8391; Temporarily ignore flaky Connect rebalance integration tests
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 the
following 100 times:
```
./gradlew connect:runtime:clean connect:runtime:test --tests
org.apache.kafka.connect.integration.RebalanceSourceConnectorsIntegrationTest
```
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`
**This should be backported to the `2.3` branch, which is when these
integration tests were first added.**
Author: Randall Hauch <rha...@gmail.com>
Reviewers: Ismael Juma
Closes #7237 from rhauch/kafka-8391-temporary
(cherry picked from commit 5b4e749dc671df583588c713913bb9eb85e67cc2)
Signed-off-by: Gwen Shapira <g...@confluent.io>
---
.../connect/integration/RebalanceSourceConnectorsIntegrationTest.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/RebalanceSourceConnectorsIntegrationTest.java
b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/RebalanceSourceConnectorsIntegrationTest.java
index ad93534..d9ff223 100644
---
a/connect/runtime/src/test/java/org/apache/kafka/connect/integration/RebalanceSourceConnectorsIntegrationTest.java
+++
b/connect/runtime/src/test/java/org/apache/kafka/connect/integration/RebalanceSourceConnectorsIntegrationTest.java
@@ -24,6 +24,7 @@ import
org.apache.kafka.connect.util.clusters.EmbeddedConnectCluster;
import org.apache.kafka.test.IntegrationTest;
import org.junit.After;
import org.junit.Before;
+import org.junit.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.slf4j.Logger;
@@ -100,6 +101,7 @@ public class RebalanceSourceConnectorsIntegrationTest {
connect.stop();
}
+ @Ignore("Flaky and disruptive. See KAFKA-8391, KAFKA-8661 for details.")
@Test
public void testStartTwoConnectors() throws Exception {
// create test topic
@@ -131,6 +133,7 @@ public class RebalanceSourceConnectorsIntegrationTest {
CONNECTOR_SETUP_DURATION_MS, "Connector tasks did not start in
time.");
}
+ @Ignore("Flaky and disruptive. See KAFKA-8391, KAFKA-8661 for details.")
@Test
public void testReconfigConnector() throws Exception {
ConnectorHandle connectorHandle =
RuntimeHandles.get().connectorHandle(CONNECTOR_NAME);
@@ -186,6 +189,7 @@ public class RebalanceSourceConnectorsIntegrationTest {
recordNum >= numRecordsProduced);
}
+ @Ignore("Flaky and disruptive. See KAFKA-8391, KAFKA-8661 for details.")
@Test
public void testDeleteConnector() throws Exception {
// create test topic
