Repository: flink Updated Branches: refs/heads/master 022cd628c -> e856071e1
[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/e856071e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e856071e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e856071e Branch: refs/heads/master Commit: e856071e16f5155932a39421b7fcaac152020ee6 Parents: 022cd62 Author: zentol <ches...@apache.org> Authored: Tue Apr 10 11:35:12 2018 +0200 Committer: zentol <ches...@apache.org> Committed: Tue Apr 10 11:35:12 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/e856071e/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); } }
