[flink] branch release-1.10 updated: [FLINK-16346][runtime][tests] Use BlockingNoOpInvokable

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.10 by this push:
     new e346215  [FLINK-16346][runtime][tests] Use BlockingNoOpInvokable
e346215 is described below

commit e346215edcf2252cc60c5cef507ea77ce2ac9aca
Author: Chesnay Schepler <ches...@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 fdac262..d9dc9ff 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;
@@ -237,8 +238,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);
                }