[
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)
