[ https://issues.apache.org/jira/browse/FLINK-20045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228543#comment-17228543 ]
Yang Wang commented on FLINK-20045: ----------------------------------- I agree with you that {{TestingLeaderElectionEventHandler}} could not be responsible for writing the leader information back to external storage(e.g. ZooKeeper, K8s ConfigMap). Then in some driver tests, we need to manually call the {{LeaderElectionDriver#writeLeaderInformation}} so that the {{LeaderRetrievalDriver}} could get the leader information. Does it make sense to you? Or you still believe that we need to use the {{DefaultLeaderElectionService}} which could write back the leader information to external storage automatically. > ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval failed with > "TimeoutException: Contender was not elected as the leader within 200000ms" > -------------------------------------------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-20045 > URL: https://issues.apache.org/jira/browse/FLINK-20045 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination > Affects Versions: 1.12.0 > Reporter: Dian Fu > Priority: Critical > Labels: test-stability > Fix For: 1.12.0 > > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=9251&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebde1&t=05b74a19-4ee4-5036-c46f-ada307df6cf0 > {code} > 2020-11-07T10:34:07.5063203Z [ERROR] > testZooKeeperLeaderElectionRetrieval(org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionTest) > Time elapsed: 202.445 s <<< ERROR! > 2020-11-07T10:34:07.5064331Z java.util.concurrent.TimeoutException: Contender > was not elected as the leader within 200000ms > 2020-11-07T10:34:07.5064946Z at > org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:153) > 2020-11-07T10:34:07.5065762Z at > org.apache.flink.runtime.testutils.CommonTestUtils.waitUntilCondition(CommonTestUtils.java:139) > 2020-11-07T10:34:07.5066565Z at > org.apache.flink.runtime.leaderelection.TestingLeaderBase.waitForLeader(TestingLeaderBase.java:48) > 2020-11-07T10:34:07.5067185Z at > org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval(ZooKeeperLeaderElectionTest.java:144) > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)