This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 493a1aa8556038283e256efc5368bd319bd06d17 Author: Roman Khachatryan <[email protected]> AuthorDate: Mon Aug 15 19:30:36 2022 +0200 [FLINK-28976][state] Don't add extra delay to the 1st materialization --- .../apache/flink/state/changelog/PeriodicMaterializationManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java b/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java index 66c75c670e9..2dfe11d3886 100644 --- a/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java +++ b/flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java @@ -114,7 +114,7 @@ class PeriodicMaterializationManager implements Closeable { LOG.info("Task {} starts periodic materialization", subtaskName); - scheduleNextMaterialization(periodicMaterializeDelay + initialDelay); + scheduleNextMaterialization(initialDelay); } }
