开发者社区> 问答> 正文

请教一下,TableEnviroment在执行sql的时候如何设置sink的并行度?

请教一下,TableEnviroment在执行sql的时候如何设置sink的并行度 ?*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-08 11:01:44 858 0
1 条回答
写回答
取消 提交回答
  • 你可以把sink 之前的table转成datastream,然后改变全局的为你想设置的sink并行度,再dataStream.addSink(sink)(由于这里会取全局并行度并给算子设置),   之后把全局并行度改回去。理论上这个方法可以为每个算子设置单独并行度 *来自志愿者整理的flink

    2021-12-08 11:17:08
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
SQL Server 2017 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载