[GitHub] [flink] hlteoh37 commented on a diff in pull request #22901: [FLINK-32469][REST] Simplify implementation of checkpoint handlers

["hlteoh37 (via GitHub)" <gi...@apache.org>]

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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org