Skip to content

Commit 1d4e366

Browse files
authored
[FLINK-36772][mysql][cdc-base] Fix error placeholder for errorMessageTemplate of Preconditions
This closes #3754
1 parent d0b2fe3 commit 1d4e366

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -428,15 +428,15 @@ public AssignerStatus getAssignerStatus() {
428428
@Override
429429
public void startAssignNewlyAddedTables() {
430430
Preconditions.checkState(
431-
isAssigningFinished(assignerStatus), "Invalid assigner status {}", assignerStatus);
431+
isAssigningFinished(assignerStatus), "Invalid assigner status %s", assignerStatus);
432432
assignerStatus = assignerStatus.startAssignNewlyTables();
433433
}
434434

435435
@Override
436436
public void onStreamSplitUpdated() {
437437
Preconditions.checkState(
438438
isNewlyAddedAssigningSnapshotFinished(assignerStatus),
439-
"Invalid assigner status {}",
439+
"Invalid assigner status %s",
440440
assignerStatus);
441441
assignerStatus = assignerStatus.onStreamSplitUpdated();
442442
}

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -471,7 +471,7 @@ public AssignerStatus getAssignerStatus() {
471471
public void startAssignNewlyAddedTables() {
472472
Preconditions.checkState(
473473
AssignerStatus.isAssigningFinished(assignerStatus),
474-
"Invalid assigner status {}",
474+
"Invalid assigner status %s",
475475
assignerStatus);
476476
assignerStatus = assignerStatus.startAssignNewlyTables();
477477
}
@@ -480,7 +480,7 @@ public void startAssignNewlyAddedTables() {
480480
public void onBinlogSplitUpdated() {
481481
Preconditions.checkState(
482482
AssignerStatus.isNewlyAddedAssigningSnapshotFinished(assignerStatus),
483-
"Invalid assigner status {}",
483+
"Invalid assigner status %s",
484484
assignerStatus);
485485
assignerStatus = assignerStatus.onBinlogSplitUpdated();
486486
}

0 commit comments

Comments
 (0)