Re: pyflink1.12 连接Mysql报错 : Missing required options

2020-12-21 文章 Wei Zhong
Hi, 正如报错中提示的,with参数里需要的是"url"参数,你可以尝试将connector.url改成url试试看会不会报错了。 > 在 2020年12月21日,13:44,肖越 <18242988...@163.com> 写道: > > 在脚本中定义了两个源数据 ddl,但是第二就总会报缺option的问题,pyflink小白,求大神解答? > #DDL定义 > source_ddl2 = """CREATE TABLE ts_pf_sec_yldrate (id DECIMAL,pf_id VARCHAR,\ > >symbol_id VARCHAR,biz_

pyflink1.12 连接Mysql报错 : Missing required options

2020-12-20 文章 肖越
在脚本中定义了两个源数据 ddl,但是第二就总会报缺option的问题,pyflink小白,求大神解答? #DDL定义 source_ddl2 = """CREATE TABLE ts_pf_sec_yldrate (id DECIMAL,pf_id VARCHAR,\ symbol_id VARCHAR,biz_date VARCHAR,\ ccy_type VARCHAR,cur_id_d VARCHAR,yldrate DECIMAL,\ is_valid DECIMAL,time_mark TIMESTAMP) WITH (