[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16789411#comment-16789411 ]
chunpinghe edited comment on FLINK-11835 at 3/12/19 1:14 AM: ------------------------------------------------------------- is it possible that the recoveryOperation hasn't finished which causes requestJobResult method to throw FlinkJobNotFoundException. requestJobResult should wait recoveryOperation complete ? was (Author: moxian): is it possible that the recoveryOperation wasn't finished which causes requestJobResult method to throw FlinkJobNotFoundException. requestJobResult should wait recoveryOperation complete ? > ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed > ------------------------------------------------------------------------------ > > Key: FLINK-11835 > URL: https://issues.apache.org/jira/browse/FLINK-11835 > Project: Flink > Issue Type: Bug > Components: Runtime / Coordination > Affects Versions: 1.8.0 > Reporter: Gary Yao > Priority: Critical > Labels: test-stability > > {noformat} > 20:44:07.264 [ERROR] > testJobExecutionOnClusterWithLeaderChange(org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase) > Time elapsed: 4.625 s <<< ERROR! > java.util.concurrent.ExecutionException: > org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find > Flink job (2e957dc4f49feaed042eb8b4a7932610) > at > org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange(ZooKeeperLeaderElectionITCase.java:152) > Caused by: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could > not find Flink job (2e957dc4f49feaed042eb8b4a7932610) > at > org.apache.flink.test.runtime.leaderelection.ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange(ZooKeeperLeaderElectionITCase.java:149) > {noformat} > https://api.travis-ci.org/v3/job/502210892/log.txt -- This message was sent by Atlassian JIRA (v7.6.3#76005)