开发者社区> 问答> 正文

PyFlink中配置作业的执行参数的代码是什么?

PyFlink中配置作业的执行参数的代码是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 14:39:22 301 0
1 条回答
写回答
取消 提交回答
  • 可以通过以下方式,配置作业的执行参数。以下示例将作业的默认并发度设置为4。
    
    t_env.get_config().get_configuration().set_string('parallelism.default', '4')
    
    2021-12-07 14:39:36
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
MaxCompute Logview参数详解和问题排查(废弃) 立即下载
Apache Flink 流式应用中状态的数据结构定义升级 立即下载
大批量处理excel文件到ODPS中方案 立即下载