huwh commented on code in PR #22861:
URL: https://github.com/apache/flink/pull/22861#discussion_r1264819557
##########
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java:
##########
@@ -68,6 +69,9 @@
public class TaskManagerServices {
private static final Logger LOG =
LoggerFactory.getLogger(TaskManagerServices.class);
+ private static final Duration SHUFFLE_DESCRIPTORS_CACHE_TIMEOUT =
Duration.ofSeconds(300);
+ private static final int SHUFFLE_DESCRIPTORS_CACHE_SIZE_LIMIT = 100;
Review Comment:
At first I chose the number of ShuffleDescriptors, but the meaning would be
more complicated for the user to understand. Now I've changed it to the number
of Groups
--
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]
