zentol commented on a change in pull request #16165:
URL: https://github.com/apache/flink/pull/16165#discussion_r656902472
##########
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingDefaultExecutionGraphBuilder.java
##########
@@ -62,10 +62,9 @@ public static TestingDefaultExecutionGraphBuilder
newBuilder() {
private ScheduledExecutorService futureExecutor =
TestingUtils.defaultExecutor();
private Executor ioExecutor = TestingUtils.defaultExecutor();
- private Time rpcTimeout = AkkaUtils.getDefaultTimeout();
+ private Time rpcTimeout =
Time.fromDuration(AkkaOptions.ASK_TIMEOUT_DURATION.defaultValue());
private ClassLoader userClassLoader =
DefaultExecutionGraph.class.getClassLoader();
private BlobWriter blobWriter = VoidBlobWriter.getInstance();
- private Time allocationTimeout = AkkaUtils.getDefaultTimeout();
Review comment:
Yes; probably when we introduce the declarative slot management because
that invalidated the allocation timeout.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
