[flink] branch master updated: [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started

[ch...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 600be00  [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started
600be00 is described below

commit 600be0097661fc3c45ef50d40f8e831421ab1d5c
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu Mar 28 13:56:52 2019 +0100

    [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started
---
 .../java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java
index ef4a2da..86d4dfa 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java
@@ -1156,7 +1156,7 @@ public class TaskExecutorTest extends TestLogger {
 			.setTaskStateManager(localStateStoresManager)
 			.build();
 
-		final TaskExecutor taskExecutor = new TaskExecutor(
+		final TestingTaskExecutor taskExecutor = new TestingTaskExecutor(
 			rpc,
 			taskManagerConfiguration,
 			haServices,
@@ -1169,6 +1169,7 @@ public class TaskExecutorTest extends TestLogger {
 
 		try {
 			taskExecutor.start();
+			taskExecutor.waitUntilStarted();
 
 			ArgumentCaptor<JobLeaderListener> jobLeaderListenerArgumentCaptor = ArgumentCaptor.forClass(JobLeaderListener.class);