This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new 16fa17e06 [FLINK-38204][pipeline-connector][maxcompute] Use
getLatestEvolvedSchema to get Schema in SessionManageOperator in case of using
route. #4094
16fa17e06 is described below
commit 16fa17e064758ef8d1de3c8a94fea7c618d4b0e1
Author: proletarians <75650402+proletari...@users.noreply.github.com>
AuthorDate: Thu Aug 14 12:51:57 2025 +0800
[FLINK-38204][pipeline-connector][maxcompute] Use getLatestEvolvedSchema to
get Schema in SessionManageOperator in case of using route. #4094
Co-authored-by: wuzexian <shanqing....@alibaba-inc.com>
---
.../cdc/connectors/maxcompute/coordinator/SessionManageOperator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java
index 3538bb3c6..d8ef141b7 100644
---
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java
+++
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java
@@ -194,7 +194,7 @@ public class SessionManageOperator extends
AbstractStreamOperator<Event>
}
private void emitLatestSchema(TableId tableId) throws Exception {
- Optional<Schema> schema =
schemaEvolutionClient.getLatestOriginalSchema(tableId);
+ Optional<Schema> schema =
schemaEvolutionClient.getLatestEvolvedSchema(tableId);
if (schema.isPresent()) {
Schema latestSchema = schema.get();
schemaMaps.put(tableId, latestSchema);
