curcur commented on a change in pull request #16606:
URL: https://github.com/apache/flink/pull/16606#discussion_r683259635
##########
File path:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
##########
@@ -127,13 +128,29 @@
private boolean forceAvro = false;
private long autoWatermarkInterval = 200;
+ // ---------- statebackend related configurations
------------------------------
/**
* Interval in milliseconds for sending latency tracking marks from the
sources to the sinks.
*/
private long latencyTrackingInterval =
MetricOptions.LATENCY_INTERVAL.defaultValue();
private boolean isLatencyTrackingConfigured = false;
+ /** Interval in milliseconds to perform periodic materialization. */
+ private long periodicMaterializeInterval =
+
StateBackendOptions.PERIODIC_MATERIALIZATION_INTERVAL.defaultValue();
+
+ /** Interval in milliseconds for initial delay of periodic
materialization. */
+ private long periodicMaterializeInitDelay =
+
StateBackendOptions.PERIODIC_MATERIALIZATION_INIT_DELAY.defaultValue();
Review comment:
That's the init delay. I can remove it if you think it is not necessary.
I do not have a strong opinion.
--
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]
