You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/07/07 14:42:20 UTC
[flink] 01/03: [hotfix][runtime] Make
TestingComponentMainThreadExecutor accept ComponentMainThreadExecutor
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0607fa50de42e38ec631e67ba3bbc9985b403aac
Author: Gary Yao <ga...@apache.org>
AuthorDate: Thu Jul 4 17:14:09 2019 +0200
[hotfix][runtime] Make TestingComponentMainThreadExecutor accept ComponentMainThreadExecutor
---
.../runtime/executiongraph/TestingComponentMainThreadExecutor.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingComponentMainThreadExecutor.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingComponentMainThreadExecutor.java
index 93131a3..56a39c0 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingComponentMainThreadExecutor.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingComponentMainThreadExecutor.java
@@ -18,6 +18,7 @@
package org.apache.flink.runtime.executiongraph;
+import org.apache.flink.runtime.concurrent.ComponentMainThreadExecutor;
import org.apache.flink.util.ExecutorUtils;
import org.apache.flink.util.function.FunctionUtils;
import org.apache.flink.util.function.SupplierWithException;
@@ -39,10 +40,10 @@ public class TestingComponentMainThreadExecutor {
/** The main thread executor to which execution is delegated. */
@Nonnull
- private final TestingComponentMainThreadExecutorServiceAdapter mainThreadExecutor;
+ private final ComponentMainThreadExecutor mainThreadExecutor;
public TestingComponentMainThreadExecutor(
- @Nonnull TestingComponentMainThreadExecutorServiceAdapter mainThreadExecutor) {
+ @Nonnull ComponentMainThreadExecutor mainThreadExecutor) {
this.mainThreadExecutor = mainThreadExecutor;
}
@@ -68,7 +69,7 @@ public class TestingComponentMainThreadExecutor {
}
@Nonnull
- public TestingComponentMainThreadExecutorServiceAdapter getMainThreadExecutor() {
+ public ComponentMainThreadExecutor getMainThreadExecutor() {
return mainThreadExecutor;
}