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:21 UTC
[flink] 02/03: [hotfix][runtime] Fix main thread check in
ComponentMainThreadExecutorServiceAdapter
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 5dc2a17891cc75b4e4a522a6ba15f253452a3b8f
Author: Gary Yao <ga...@apache.org>
AuthorDate: Thu Jul 4 17:23:29 2019 +0200
[hotfix][runtime] Fix main thread check in ComponentMainThreadExecutorServiceAdapter
---
.../runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java b/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java
index c71675a..e3b0690 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java
@@ -48,7 +48,9 @@ public class ComponentMainThreadExecutorServiceAdapter implements ComponentMainT
public ComponentMainThreadExecutorServiceAdapter(
final ScheduledExecutor scheduledExecutorService,
final Thread mainThread) {
- this(scheduledExecutorService, () -> MainThreadValidatorUtil.isRunningInExpectedThread(mainThread));
+ this(scheduledExecutorService, () -> {
+ assert MainThreadValidatorUtil.isRunningInExpectedThread(mainThread);
+ });
}
private ComponentMainThreadExecutorServiceAdapter(