masteryhx commented on code in PR #20585:
URL: https://github.com/apache/flink/pull/20585#discussion_r946405835
##########
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/PeriodicMaterializationManager.java:
##########
@@ -118,7 +118,7 @@ public void start() {
LOG.info("Task {} starts periodic materialization", subtaskName);
- scheduleNextMaterialization(periodicMaterializeDelay +
initialDelay);
+ scheduleNextMaterialization(initialDelay);
Review Comment:
I think disabling materialization for test is not the main purpose of this
pr, right ?
(Diabling has been supported in
[FLINK-26673](https://issues.apache.org/jira/browse/FLINK-26673))
About making the checkpoint deletion evenly, It is not enough for users to
using changlog out of box without configuring other configs like
[jobmanager.io-pool.size](https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/#jobmanager-io-pool-size)
?
We may still need other strategy to solve the problem of the checkpoint
deletion delay ?
--
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]
