You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/10 09:39:35 UTC
flink git commit: [hotfix][tests] Fix job-cancellation check in
ResumeCheckpointManuallyITCase
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 <ch...@apache.org>
Authored: Tue Apr 10 11:35:12 2018 +0200
Committer: zentol <ch...@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);
}
}