Re: pyflink1.12 使用connector read.query参数报错

Thu, 24 Dec 2020 03:34:43 -0800 

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/

回复