[flink] branch release-1.8 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 release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git


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

commit d68c45e05b6a9ec1cf3fc49e1d82a863795f7341
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 513e0ea..34ce4b3 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
@@ -1139,7 +1139,7 @@ public class TaskExecutorTest extends TestLogger {
                        .setTaskStateManager(localStateStoresManager)
                        .build();
 
-               final TaskExecutor taskExecutor = new TaskExecutor(
+               final TestingTaskExecutor taskExecutor = new 
TestingTaskExecutor(
                        rpc,
                        taskManagerConfiguration,
                        haServices,
@@ -1152,6 +1152,7 @@ public class TaskExecutorTest extends TestLogger {
 
                try {
                        taskExecutor.start();
+                       taskExecutor.waitUntilStarted();
 
                        ArgumentCaptor<JobLeaderListener> 
jobLeaderListenerArgumentCaptor = 
ArgumentCaptor.forClass(JobLeaderListener.class);