Yanquan Lv created FLINK-38204:
----------------------------------
Summary: 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
Reporter: Yanquan Lv
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)
