hi??All????????blink planner??batch mode????????mysql????????????????JDBC 
Connector????????
CREATE TABLE MyUserTable (   ... ) WITH (   'connector.type' = 'jdbc', -- 
required: specify this table type is jdbc      'connector.url' = 
'jdbc:mysql://localhost:3306/flink-test', -- required: JDBC DB url      
'connector.table' = 'jdbc_table_name',  -- required: jdbc table name      
'connector.driver' = 'com.mysql.jdbc.Driver', -- optional: the class name of 
the JDBC driver to use to connect to this URL.                                  
                -- If not set, it will automatically be derived from the URL.   
 'connector.username' = 'name', -- optional: jdbc user name and password   
'connector.password' = 'password',
'connector.write.flush.max-rows' = '5000'


?????????????????????????? MyUserTable????????????????????????flink 
env??????????MySQL??????sql??????????select * from student where score > 
60"??????????????????????????????????????????????????????????????????????????????????????????????blink
 planner ??batch mode????JDBC??????????????Thanks!

回复