提交 6b60e67b 编写于 作者: Z zentol 提交者: Chesnay Schepler

[FLINK-11690][runtime] Use configured RPC timeout in MiniCluster

上级 04ede2c6
......@@ -187,7 +187,7 @@ public class MiniCluster implements JobExecutorService, AutoCloseableAsync {
this.rpcServices = new ArrayList<>(1 + 2 + miniClusterConfiguration.getNumTaskManagers()); // common + JM + RM + TMs
this.dispatcherResourceManagerComponents = new ArrayList<>(1);
this.rpcTimeout = Time.seconds(10L);
this.rpcTimeout = miniClusterConfiguration.getRpcTimeout();
this.terminationFuture = CompletableFuture.completedFuture(null);
running = false;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册