Skip to content

Commit 5cd56a9

Browse files
committed
hotfix OceanBaseE2eITCase source e2e test
1 parent 39608ed commit 5cd56a9

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/OceanBaseE2eITCase.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,8 @@ public void testOceanBaseCDC() throws Exception {
175175
"107,rocks,box of assorted rocks,5.1,null,null",
176176
"108,jacket,water resistent black wind breaker,0.1,null,null",
177177
"109,spare tire,24 inch spare tire,22.2,null,null",
178-
"110,jacket,new water resistent white wind breaker,0.5,null,null");
178+
"110,jacket,new water resistent white wind breaker,0.5,null,null",
179+
"111,scooter,Big 2-wheel scooter,5.18, null, null");
179180
proxy.checkResultWithTimeout(
180181
expectResult,
181182
"ob_products_sink",

0 commit comments

Comments
 (0)