BugFix: fix test case

yuanoOo · yuanoOo · commit 41a9adbc2ffb · 2025-09-16T15:30:36.000+08:00
diff --git a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/OceanBaseE2eITCase.java b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/OceanBaseE2eITCase.java
@@ -197,7 +197,7 @@ void testOBBinlogCDC() throws Exception {
                 expectResult,
                 "products_sink",
                 new String[] {"id", "name", "description", "weight", "enum_c", "json_c", "point_c"},
-                60000L);
+                150000L);
     }
 
     /** Creates the database and populates it with initialization SQL script. */

Original file line number	Diff line number	Diff line change
`@@ -197,7 +197,7 @@ void testOBBinlogCDC() throws Exception {`
`197`	`197`	`expectResult,`
`198`	`198`	`"products_sink",`
`199`	`199`	`new String[] {"id", "name", "description", "weight", "enum_c", "json_c", "point_c"},`
`200`		`- 60000L);`
	`200`	`+ 150000L);`
`201`	`201`	`}`
`202`	`202`
`203`	`203`	`/** Creates the database and populates it with initialization SQL script. */`