请教下,看了这篇文章https://developer.aliyun.com/article/771438,flink-cdc 读取mysql
Maxwell 格式binlog,怎么在flink 源表上获取mysql表名,通过这样的方式并没有生效  `origin_table` STRING
METADATA FROM 'value.source.table' VIRTUAL,

https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connectors/kafka.html

<http://apache-flink.147419.n8.nabble.com/file/t572/lALPDg7mQSzBJifNAmzNBpY_1686_620.png>
 



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复