[
https://issues.apache.org/jira/browse/FLINK-38204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv reassigned FLINK-38204:
----------------------------------
Assignee: Yanquan Lv
> When using route in pipeline, failed to write to MaxCompute sink
> ----------------------------------------------------------------
>
> Key: FLINK-38204
> URL: https://issues.apache.org/jira/browse/FLINK-38204
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.4.0
> Reporter: Yanquan Lv
> Assignee: Yanquan Lv
> Priority: Major
>
> Example of my job config:
> {code:yaml}
> source:
> type: mysql
> hostname: xx
> port: 3306
> username: xx
> password: xx
> tables: odin.task_query_batch_detail_save_[2-9][5-9]_\.*
> server-id: 5401-5404
> scan.startup.mode : latest-offset
> sink:
> type: maxcompute
> project: xx
> endpoint: xx
> tunnel.endpoint: xx
> access-id: xx
> access-key: xx
> buckets-num: 4
> bucket.buffer-size: 1MB
> quota.name : xx
> useStreamTunnel : true
> schema-operator.rpc-timeout: 6min
> route:
> - source-table: odin.task_query_batch_detail_save_[2-9][5-9]_\.*
> sink-table: tcods_xybk_odin_task_query_batch_detail_save_tmp
> {code}
> When I try to start my job, I get following error message:
> {code:java}
> java.lang.RuntimeException: Could not find schema message from SchemaRegistry
> for tcods_xybk_odin_task_query_batch_detail_save_tmp
> at
> org.apache.flink.cdc.connectors.maxcompute.coordinator.SessionManageOperator.emitLatestSchema
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
