flink sql客户端设置并行度
时间: 2023-09-19 15:11:07 浏览: 371
在 Flink SQL 中,可以通过以下两种方式设置并行度:
1. 通过设置 Flink 系统参数 flink.parallelism.default。该参数是 Flink 默认的并行度,如果没有在具体的操作中设置并行度,则会使用该默认值。可以在启动 Flink 集群时通过修改 flink-conf.yaml 文件来设置该参数的值。
2. 在具体的 SQL 操作中使用关键字 PARALLELISM 来指定并行度。例如:
```
SELECT *
FROM myTable
WHERE age > 18
PARALLELISM 4;
```
上述语句指定了该操作的并行度为 4。注意,该方式只对具体的操作生效,不会影响到其他操作的并行度。
阅读全文