Repository: flink
Updated Branches:
  refs/heads/release-1.5 0ec37e44c -> 4e69adfbe


[hotfix][tests] Fix job-cancellation check in ResumeCheckpointManuallyITCase


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4e69adfb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4e69adfb
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4e69adfb

Branch: refs/heads/release-1.5
Commit: 4e69adfbef0bdeeb5e14495052f067ae4f487781
Parents: 0ec37e4
Author: zentol <ches...@apache.org>
Authored: Tue Apr 10 11:35:12 2018 +0200
Committer: zentol <ches...@apache.org>
Committed: Tue Apr 10 11:39:55 2018 +0200

----------------------------------------------------------------------
 .../flink/test/checkpointing/ResumeCheckpointManuallyITCase.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/4e69adfb/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ResumeCheckpointManuallyITCase.java
----------------------------------------------------------------------
diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ResumeCheckpointManuallyITCase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ResumeCheckpointManuallyITCase.java
index add4243..6f5bbac 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ResumeCheckpointManuallyITCase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ResumeCheckpointManuallyITCase.java
@@ -344,7 +344,7 @@ public class ResumeCheckpointManuallyITCase extends 
TestLogger {
        }
 
        private static void waitUntilCanceled(JobID jobId, ClusterClient<?> 
client) throws ExecutionException, InterruptedException {
-               while (client.getJobStatus(jobId).get() != 
JobStatus.CANCELLING) {
+               while (client.getJobStatus(jobId).get() != JobStatus.CANCELED) {
                        Thread.sleep(50);
                }
        }

Reply via email to