谢谢,老师们的指导,根据嘉伟的建议,发现pyflink1.12确实并不支持这个参数~
还是希望官方能够开放这个参数,就目前的工作情景来说,取数据就需要定义整张表,如果数据库更改,代码这边很不便于维护; 从本机的实验结果上看,pyflink内部进行query的效率并不高,正准备放到集群上试试~ 在 2020-12-25 09:45:28,"Leonard Xu" <xbjt...@gmail.com> 写道: >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/ >