nicoweidner commented on a change in pull request #16543:
URL: https://github.com/apache/flink/pull/16543#discussion_r676669939
##########
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java
##########
@@ -159,6 +160,8 @@ private void
setupAndRunHandleJobsWhenNotEnoughSlots(ScheduleMode scheduleMode)
private void runHandleJobsWhenNotEnoughSlots(final JobGraph jobGraph)
throws Exception {
final Configuration configuration = getDefaultConfiguration();
configuration.setLong(JobManagerOptions.SLOT_REQUEST_TIMEOUT, 100L);
+ configuration.setLong(
+ ResourceManagerOptions.STANDALONE_CLUSTER_STARTUP_PERIOD_TIME,
10000L);
Review comment:
Thanks for the explanations! I got confused by:
- Not understanding properly how slot requests are handled for batch jobs
- Spending too much time in breakpoints while debugging, causing a different
exception to be thrown :D (because timeout had elapsed in the meantime...)
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
