[
https://issues.apache.org/jira/browse/KAFKA-15292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez updated KAFKA-15292:
--------------------------------
Issue Type: Test (was: Bug)
> Flaky test IdentityReplicationIntegrationTest#testReplicateSourceDefault()
> --------------------------------------------------------------------------
>
> Key: KAFKA-15292
> URL: https://issues.apache.org/jira/browse/KAFKA-15292
> Project: Kafka
> Issue Type: Test
> Components: mirrormaker
> Reporter: Kirk True
> Priority: Major
> Labels: flaky-test, mirror-maker, mirrormaker
>
> The test testReplicateSourceDefault in
> `org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest
> is flaky about 2% of the time as shown in [Gradle
> Enterprise|[https://ge.apache.org/scans/tests?search.relativeStartTime=P90D&search.rootProjectNames=kafka&search.timeZoneId=America/Los_Angeles&tests.container=org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest&tests.sortField=FLAKY]].
>
> {code:java}
> java.lang.RuntimeException: Could not stop worker
> at
> o.a.k.connect.util.clusters.EmbeddedConnectCluster.stopWorker(EmbeddedConnectCluster.java:230)
> at java.lang.Iterable.forEach(Iterable.java:75)
> at
> o.a.k.connect.util.clusters.EmbeddedConnectCluster.stop(EmbeddedConnectCluster.java:163)
> at
> o.a.k.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest.shutdownClusters(MirrorConnectorsIntegrationBaseTest.java:267)
> at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
> at
> jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:568)
> at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
> ...
> at
> worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
> Caused by: java.lang.IllegalStateException: !STOPPED
> at
> org.eclipse.jetty.server.handler.HandlerWrapper.destroy(HandlerWrapper.java:140)
> at o.a.k.connect.runtime.rest.RestServer.stop(RestServer.java:361)
> at o.a.k.connect.runtime.Connect.stop(Connect.java:69) at
> o.a.k.connect.util.clusters.WorkerHandle.stop(WorkerHandle.java:57)
> at
> o.a.k.connect.util.clusters.EmbeddedConnectCluster.stopWorker(EmbeddedConnectCluster.java:225)
> ... 93 more{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
