Hi, 小学生 1. 关于问题1，这个是支持的，你通过TableEnvrironment的sql_update就行 例如： s_env = StreamExecutionEnvironment.get_execution_environment() s_env.set_parallelism(1) st_env = StreamTableEnvironment.create(s_env)
mysql_source_ddl = """ CREATE TABLE buybacksource ( a VARCHAR, b VARCHAR, c VARCHAR, proctime AS PROCTIME() ) WITH ( 'connector.type' = 'jdbc', 'connector.url' = 'jdbc:mysql://***/***', 'connector.table' = '***', 'connector.username' = '***', 'connector.password' = '***', 'connector.write.flush.interval' = '1s' """ st_env.sql_update(mysql_source_ddl) 2. 关于问题2， 你是想查看Table里的数据吗？这个和Java的Table一样，你要查看Table的数据，你得sink出来才能查看数据 Best, Xingbo 小学生 <[email protected]> 于2020年6月4日周四 下午4:53写道： > 各位大佬好，想咨询几个问题： > 1.pyflink sql中update操作是不是在1.10.0版本没有呢？ > 2.pyflink内置表类型Table是否可直观查看类内的数据项？
