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

[chesnay]

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 <ches...@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);