回复：pyflink 1.11 connector数据读取问题

写个程序自动根据表的元数据生成ddl语句 ---原始邮件--- 发件人: "肖越"<18242988...@163.com 发送时间: 2021年1月27日(周三) 下午3:29 收件人: "user-zh"

pyflink 1.11 connector数据读取问题

目前通过 connector 定义ddl的方式，通过数据库读取数据，方式如下： CREATE TABLE MyUserTable ( id BIGINT, name STRING, age INT, status BOOLEAN, PRIMARY KEY (id) NOT ENFORCED ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://localhost:3306/mydatabase', 'table-name' = 'users' ); 每次表格获取及定义都需要定义数据类型（如例子中: