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/03 23:03:34 UTC
[flink] 02/04: [hotfix][runtime,
tests] Remove ComponentMainThreadExecutor interface from
ManuallyTriggeredScheduledExecutor
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 9a0c965aaac9b4c786decdb4a76d7167520e9776
Author: Gary Yao <ga...@apache.org>
AuthorDate: Thu Jun 27 17:05:28 2019 +0200
[hotfix][runtime, tests] Remove ComponentMainThreadExecutor interface from ManuallyTriggeredScheduledExecutor
---
.../runtime/concurrent/ManuallyTriggeredScheduledExecutor.java | 6 +-----
1 file changed, 1 insertion(+), 5 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ManuallyTriggeredScheduledExecutor.java b/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ManuallyTriggeredScheduledExecutor.java
index dd307c4..870cda8 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ManuallyTriggeredScheduledExecutor.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ManuallyTriggeredScheduledExecutor.java
@@ -39,7 +39,7 @@ import java.util.concurrent.TimeoutException;
/**
* Simple {@link ScheduledExecutor} implementation for testing purposes.
*/
-public class ManuallyTriggeredScheduledExecutor implements ScheduledExecutor, ComponentMainThreadExecutor {
+public class ManuallyTriggeredScheduledExecutor implements ScheduledExecutor {
private final Executor executorDelegate;
private final ArrayDeque<Runnable> queuedRunnables = new ArrayDeque<>();
@@ -148,10 +148,6 @@ public class ManuallyTriggeredScheduledExecutor implements ScheduledExecutor, Co
return scheduledTask;
}
- @Override
- public void assertRunningInMainThread() {
- }
-
private static final class ScheduledTask<T> implements ScheduledFuture<T> {
private final Callable<T> callable;