[flink] branch master updated: [FLINK-32769][hotfix][state-changelog] Fix the invalid placeholder {} passed to MailboxExecutor#execute() in PeriodicMaterializationManager (#23153)

[leiyanfei]

This is an automated email from the ASF dual-hosted git repository.

leiyanfei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 13469792821 [FLINK-32769][hotfix][state-changelog] Fix the invalid 
placeholder {} passed to MailboxExecutor#execute() in 
PeriodicMaterializationManager (#23153)
13469792821 is described below

commit 13469792821ee1e9d2171a28a071cc986626316e
Author: Wang FeiFan <zoltar9...@163.com>
AuthorDate: Fri Sep 15 16:50:58 2023 +0800

    [FLINK-32769][hotfix][state-changelog] Fix the invalid placeholder {} 
passed to MailboxExecutor#execute() in PeriodicMaterializationManager (#23153)
    
    Co-authored-by: Yanfei Lei <18653940+fre...@users.noreply.github.com>
---
 .../org/apache/flink/state/common/PeriodicMaterializationManager.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java
 
b/flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java
index 68bee356208..7989ea31cfb 100644
--- 
a/flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java
+++ 
b/flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java
@@ -267,7 +267,7 @@ public class PeriodicMaterializationManager implements 
Closeable {
                                                 
metrics.reportFailedMaterialization();
                                             }
                                         },
-                                        "Task {} update materializedSnapshot 
up to changelog sequence number: {}",
+                                        "Task %s update materializedSnapshot 
up to changelog sequence number: %s.",
                                         subtaskName,
                                         upTo);
 
@@ -310,7 +310,7 @@ public class PeriodicMaterializationManager implements 
Closeable {
                 () ->
                         target.handleMaterializationFailureOrCancellation(
                                 materializationId, upTo, cause),
-                "Task {} materialization:{},upTo:{} failed or canceled.",
+                "Task %s materialization: %d, upTo: %s, failed or canceled.",
                 subtaskName,
                 materializationId,
                 upTo);