提交 a3035535 编写于 作者: T Till Rohrmann

[hotfix] Harden TaskExecutorTest#testHeartbeatTimeoutWithJobManager by increasing timeout

In order to check whether the heartbeat manager detects timeouts we wait on the
JobMasterGateway.disconnectTaskManager call which happens asynchronously. In order to harden
the test, we increase the timeout from 50 ms to 500 ms for the timeout call to happen.
上级 12487231
......@@ -199,7 +199,7 @@ public class TaskExecutorTest extends TestLogger {
eq(taskManager.getAddress()), eq(taskManagerLocation), eq(jmLeaderId), any(Time.class));
// the timeout should trigger disconnecting from the JobManager
verify(jobMasterGateway, timeout(heartbeatTimeout * 5)).disconnectTaskManager(eq(taskManagerLocation.getResourceID()), any(TimeoutException.class));
verify(jobMasterGateway, timeout(heartbeatTimeout * 50L)).disconnectTaskManager(eq(taskManagerLocation.getResourceID()), any(TimeoutException.class));
// check if a concurrent error occurred
testingFatalErrorHandler.rethrowError();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册