gaborgsomogyi commented on code in PR #513:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/513#discussion_r1090405326
##########
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java:
##########
@@ -379,6 +379,24 @@ public static String operatorConfigKey(String key) {
"The threshold which is checked against job
restart count within a configured window. "
+ "If the restart count is reaching the
threshold then full cluster restart is initiated.");
+ @Documentation.Section(SECTION_DYNAMIC)
+ public static final ConfigOption<Boolean>
+ OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_ENABLED =
+
operatorConfig("cluster.health-check.checkpoint-progress.enabled")
+ .booleanType()
+ .defaultValue(false)
+ .withDescription(
+ "Whether to enable checkpoint progress
health check for clusters.");
+
+ @Documentation.Section(SECTION_DYNAMIC)
+ public static final ConfigOption<Duration>
+ OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_WINDOW =
+
operatorConfig("cluster.health-check.checkpoint-progress.window")
+ .durationType()
+ .defaultValue(Duration.ofMinutes(5))
+ .withDescription(
+ "The duration of the time window where job
completed checkpoint count measured. This must be bigger than checkpointing
interval.");
Review Comment:
Changed.
--
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]
