fixup! [FLINK-36701][cdc-runtime] Add steps to get and emit schemaManager's latest evolvedSchema when SinkDataWriterOperator handles FlushEvent.

Jzjsnow · Jzjsnow · commit e0a3e30f14fd · 2025-01-07T10:13:54.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
@@ -180,6 +180,6 @@ public void testOceanBaseCDC() throws Exception {
                 expectResult,
                 "ob_products_sink",
                 new String[] {"id", "name", "description", "weight", "enum_c", "json_c"},
-                60000L);
+                300000L);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -180,6 +180,6 @@ public void testOceanBaseCDC() throws Exception {`
`180`	`180`	`expectResult,`
`181`	`181`	`"ob_products_sink",`
`182`	`182`	`new String[] {"id", "name", "description", "weight", "enum_c", "json_c"},`
`183`		`- 60000L);`
	`183`	`+ 300000L);`
`184`	`184`	`}`
`185`	`185`	`}`