?????? pyflink 1.11.1 execute_sql sql_update????????????????????????????????????????????, ??????????????Deprecated
---- ??: "user-zh"
pyflink 1.11.1 execute_sql sql_update????????????????????????????????????????????, ??????????????Deprecated
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 =