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 2020/05/11 07:21:06 UTC
[flink] branch release-1.9 updated: [FLINK-16346][runtime][tests]
Use BlockingNoOpInvokable
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new 36440fb [FLINK-16346][runtime][tests] Use BlockingNoOpInvokable
36440fb is described below
commit 36440fb938b50aecd2c8de607806f381cc2af587
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu May 7 12:19:53 2020 +0200
[FLINK-16346][runtime][tests] Use BlockingNoOpInvokable
---
.../java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java
index 4e53b4e..88d66ae 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/BlobsCleanupITCase.java
@@ -34,6 +34,7 @@ import org.apache.flink.runtime.jobgraph.JobGraph;
import org.apache.flink.runtime.jobgraph.JobVertex;
import org.apache.flink.runtime.jobmaster.JobResult;
import org.apache.flink.runtime.minicluster.MiniCluster;
+import org.apache.flink.runtime.testtasks.BlockingNoOpInvokable;
import org.apache.flink.runtime.testtasks.FailingBlockingInvokable;
import org.apache.flink.runtime.testtasks.NoOpInvokable;
import org.apache.flink.runtime.testutils.MiniClusterResource;
@@ -231,8 +232,10 @@ public class BlobsCleanupITCase extends TestLogger {
@Nonnull
private JobGraph createJobGraph(TestCase testCase, int numTasks) {
JobVertex source = new JobVertex("Source");
- if (testCase == TestCase.JOB_FAILS || testCase == TestCase.JOB_IS_CANCELLED) {
+ if (testCase == TestCase.JOB_FAILS) {
source.setInvokableClass(FailingBlockingInvokable.class);
+ } else if (testCase == TestCase.JOB_IS_CANCELLED) {
+ source.setInvokableClass(BlockingNoOpInvokable.class);
} else {
source.setInvokableClass(NoOpInvokable.class);
}