Skip to content

Commit 92f0aa6

Browse files
author
wangjunbo
committed
correct the checkpointId for MultiTableCommittable
1 parent 99d0324 commit 92f0aa6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonSinkITCase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ public class PaimonSinkITCase {
8484

8585
private BinaryRecordDataGenerator generator;
8686

87-
private static int checkpointId = 0;
87+
private static int checkpointId = 1;
8888

8989
public static final String TEST_DATABASE = "test";
9090
private static final String HADOOP_CONF_DIR =

0 commit comments

Comments
 (0)