(flink-cdc) branch master updated: [FLINK-36772][mysql][cdc-base] Fix error placeholder for errorMessageTemplate of Preconditions

[leonard]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 1d4e36696 [FLINK-36772][mysql][cdc-base] Fix error placeholder for 
errorMessageTemplate of Preconditions
1d4e36696 is described below

commit 1d4e36696966a5d25680cc8cbbbbe169d4ba72a7
Author: Xin Gong <genzhedangd...@gmail.com>
AuthorDate: Fri Nov 22 16:02:24 2024 +0800

    [FLINK-36772][mysql][cdc-base] Fix error placeholder for 
errorMessageTemplate of Preconditions
    
    This closes  #3754
---
 .../cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java    | 4 ++--
 .../connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java
index a3a234b73..d534aef63 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java
@@ -428,7 +428,7 @@ public class SnapshotSplitAssigner<C extends SourceConfig> 
implements SplitAssig
     @Override
     public void startAssignNewlyAddedTables() {
         Preconditions.checkState(
-                isAssigningFinished(assignerStatus), "Invalid assigner status 
{}", assignerStatus);
+                isAssigningFinished(assignerStatus), "Invalid assigner status 
%s", assignerStatus);
         assignerStatus = assignerStatus.startAssignNewlyTables();
     }
 
@@ -436,7 +436,7 @@ public class SnapshotSplitAssigner<C extends SourceConfig> 
implements SplitAssig
     public void onStreamSplitUpdated() {
         Preconditions.checkState(
                 isNewlyAddedAssigningSnapshotFinished(assignerStatus),
-                "Invalid assigner status {}",
+                "Invalid assigner status %s",
                 assignerStatus);
         assignerStatus = assignerStatus.onStreamSplitUpdated();
     }
diff --git 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
index 89985ae2f..0382cf6e7 100644
--- 
a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
+++ 
b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java
@@ -471,7 +471,7 @@ public class MySqlSnapshotSplitAssigner implements 
MySqlSplitAssigner {
     public void startAssignNewlyAddedTables() {
         Preconditions.checkState(
                 AssignerStatus.isAssigningFinished(assignerStatus),
-                "Invalid assigner status {}",
+                "Invalid assigner status %s",
                 assignerStatus);
         assignerStatus = assignerStatus.startAssignNewlyTables();
     }
@@ -480,7 +480,7 @@ public class MySqlSnapshotSplitAssigner implements 
MySqlSplitAssigner {
     public void onBinlogSplitUpdated() {
         Preconditions.checkState(
                 
AssignerStatus.isNewlyAddedAssigningSnapshotFinished(assignerStatus),
-                "Invalid assigner status {}",
+                "Invalid assigner status %s",
                 assignerStatus);
         assignerStatus = assignerStatus.onBinlogSplitUpdated();
     }