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 <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 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); }