开发者社区 问答 正文

PyFlink中配置DataStream API作业的执行参数的方法是什么?

PyFlink中配置DataStream API作业的执行参数的方法是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 14:56:27 417 分享 版权
1 条回答
写回答
取消 提交回答
  • 2)配置作业的执行参数
    
    可以通过以下方式,配置作业的执行参数。以下示例将作业的默认并发度设置为4。
    
    env.set_parallelism(4)
    
    2021-12-07 14:56:40
    赞同 展开评论