?????? pyflink 1.11.1 execute_sql sql_update????????????????????????????????????????????, ??????????????Deprecated

2020-08-12 文章 xuzh
---- ??: "user-zh"

pyflink 1.11.1 execute_sql sql_update????????????????????????????????????????????, ??????????????Deprecated

2020-08-12 文章 ??????
from pyflink.datastream import StreamExecutionEnvironment from pyflink.table import EnvironmentSettings, StreamTableEnvironment # pyflink 1.11.1 environment_settings = EnvironmentSettings.new_instance().in_streaming_mode().use_blink_planner().build() senv =