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

Reply via email to