Flink sql 1.14 并行度设置

• code
• table
• stream 模式下分区提交方式

    tEnv.getConfig.setSqlDialect(SqlDialect.HIVE)
    tEnv.getConfig.getConfiguration.set[java.lang.Boolean](HiveOptions.TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM, false)
    tEnv.getConfig.getConfiguration.set[Integer](HiveOptions.TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM_MAX, 8)

alter table table_name set TBLPROPERTIES ('sink.parallelism' = '10');

alter table table_name set TBLPROPERTIES ('sink.partition-commit.policy.kind'='metastore,success-file');