[KAFKA-15292] Flaky test IdentityReplicationIntegrationTest#testReplicateSourceDefault()

• Type: Test
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 4.0.0
• Component/s: mirrormaker
• Labels: flaky-test mirror-maker mirrormaker
• Assignee: Unassigned
• Reporter: Kirk True
• Created: 01/Aug/23 22:19
• Updated: 06/Aug/24 18:53
• Resolved: 06/Aug/24 18:53

Description

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].

 

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

Issue Links

• relates to: KAFKA-15392 RestServer starts but does not stop ServletContextHandler