afedulov commented on code in PR #656:
URL: 
https://github.com/apache/flink-kubernetes-operator/pull/656#discussion_r1303473049


##########
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/KubernetesOperatorConfigOptions.java:
##########
@@ -321,7 +336,32 @@ public static String operatorConfigKey(String key) {
                                     + "but to complement them in special 
cases. For instance, a "
                                     + "full checkpoint might need to be 
occasionally triggered to "
                                     + "break the chain of incremental 
checkpoints and consolidate "
-                                    + "the partial incremental files.");
+                                    + "the partial incremental files. "
+                                    + "WARNING: not intended to be used 
together with the cron-based "
+                                    + "periodic checkpoint triggering");
+
+    @Documentation.Section(SECTION_DYNAMIC)
+    public static final ConfigOption<String> PERIODIC_CHECKPOINT_CRON =
+            operatorConfig("periodic.checkpoint.cron")
+                    .stringType()
+                    .defaultValue(
+                            "0 0 0 29 2 ? 1999") // Default value that is 
guaranteed not to trigger (not a leap year)
+                    .withDescription(
+                            "A cron expression that defines when to 
automatically trigger checkpoints. "
+                                    + "The precise triggering schedule is not 
guaranteed, checkpoints will "
+                                    + "be triggered as part of the regular 
reconcile loop. Periodic triggering "
+                                    + "with frequency higher than the 
reconciliation loop "
+                                    + "("
+                                    + OPERATOR_RECONCILE_INTERVAL.key()
+                                    + ") will lead to trigger omissions. "
+                                    + "NOTE: checkpoints are generally managed 
by Flink. This "
+                                    + "setting isn't meant to replace Flink's 
checkpoint settings, "
+                                    + "but to complement them in special 
cases. For instance, a "
+                                    + "full checkpoint might need to be 
occasionally triggered to "
+                                    + "break the chain of incremental 
checkpoints and consolidate "
+                                    + "the partial incremental files. "
+                                    + "WARNING: not intended to be used 
together with the interval-based "
+                                    + "periodic checkpoint triggering");

Review Comment:
   After thinking about this a bit more, I guess a generic error message saying 
`something is wrong with the format, please make sure to either use a valid 
Duration data type or a cron expression` should also be OK.



-- 
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]

Reply via email to