Hi, 嘉伟 1.12 应该不支持 read.query， 社区还在讨论是否要开放这个，有些concern, 简单的讲，就如你这个query写的，创建的这张JDBC 表应该是一个 View 而不是对应一张JDBC 表，同时这个表只能用来作为source，不能用来作为sink。
祝好， Leonard > 在 2020年12月24日，19:16，冯嘉伟 <1425385...@qq.com> 写道： > > hi! 试试这个 > > CREATE TABLE source_table( > yldrate DECIMAL, > pf_id VARCHAR, > symbol_id VARCHAR) WITH( > 'connector' = 'jdbc', > 'url' = 'jdbc:mysql://ip/db', > 'driver' = 'com.mysql.cj.jdbc.Driver', > 'username' = 'xxx', > 'password' = 'xxx', > 'table-name' = 'TS_PF_SEC_YLDRATE', > 'read.query' = 'SELECT YLDRATE, PF_ID, SYMBOL_ID FROM > TS_PF_SEC_YLDRATE LEFT JOIN TP_GL_DAY ON DAY_ID = BIZ_DATE WHERE CCY_TYPE = > "AC" AND PF_ID = "1030100122" AND SYMBOL_ID = "2030004042" AND BIZ_DATE > between "20160701" AND "20170307"' > ) > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
