[
https://issues.apache.org/jira/browse/FLINK-31379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698341#comment-17698341
]
Matthias Pohl commented on FLINK-31379:
---------------------------------------
Another workaround to cover the issue which is closer to reality is that we use
separate client for each LeaderElectionService. This will avoid using the same
event queue and breaks the strict orderness of events between different
LeaderElectionService instances.
> ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers
> runs into timeout
> ----------------------------------------------------------------------------------------------------------
>
> Key: FLINK-31379
> URL: https://issues.apache.org/jira/browse/FLINK-31379
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.16.1
> Reporter: Matthias Pohl
> Priority: Major
> Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46843&view=logs&j=a57e0635-3fad-5b08-57c7-a4142d7d6fa9&t=2ef0effc-1da1-50e5-c2bd-aab434b1c5b7&l=9655
> {code}
> Mar 06 12:16:45 "ForkJoinPool-51-worker-25" #645 daemon prio=5 os_prio=0
> tid=0x00007fe20f633000 nid=0xdd4 waiting on condition [0x00007fe0342c5000]
> Mar 06 12:16:45 java.lang.Thread.State: WAITING (parking)
> Mar 06 12:16:45 at sun.misc.Unsafe.park(Native Method)
> Mar 06 12:16:45 - parking to wait for <0x00000000d213d1f8> (a
> java.util.concurrent.CompletableFuture$Signaller)
> Mar 06 12:16:45 at
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> Mar 06 12:16:45 at
> java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
> Mar 06 12:16:45 at
> java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3313)
> Mar 06 12:16:45 at
> java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
> Mar 06 12:16:45 at
> java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1947)
> Mar 06 12:16:45 at
> org.apache.flink.runtime.leaderelection.ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers(ZooKeeperMultipleComponentLeaderElectionDriverTest.java:256)
> Mar 06 12:16:45 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> [...]
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
