You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2023/09/15 08:51:10 UTC
[flink] branch master updated: [FLINK-32769][hotfix][state-changelog] Fix the invalid placeholder {} passed to MailboxExecutor#execute() in PeriodicMaterializationManager (#23153)
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 <zo...@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 <18...@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);