hlteoh37 commented on code in PR #22901:
URL: https://github.com/apache/flink/pull/22901#discussion_r1252014657
##########
flink-core/src/main/java/org/apache/flink/configuration/RestOptions.java:
##########
@@ -193,6 +193,28 @@ public class RestOptions {
+ "Lowering the thread priority will give
Flink's main components more CPU time whereas "
+ "increasing will allocate more time for
the REST server's processing.");
+ /**
+ * Duration from write after which cached checkpoints statistics are
cleaned up. It can be
+ * specified using notation: "500 ms", "1 s".
+ */
+ @Documentation.Section(Documentation.Sections.EXPERT_REST)
+ public static final ConfigOption<Duration>
CACHE_CHECKPOINT_STATISTICS_TIMEOUT =
+ key("rest.cache.checkpoint-statistics.timeout")
+ .durationType()
+ .defaultValue(Duration.ofSeconds(3))
+ .withDescription(
+ "Duration from write after which cached
checkpoints statistics are cleaned up. It can"
+ + " be specified using notation: \"500
ms\", \"1 s\".");
Review Comment:
Good point. Will incorporate feedback
--
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]
