flink sql job 并行度

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

flink sql job 并行度

lucas.wu
Hi all:
最近在使用flink sql 做一些计算任务,发现如果一条sql被解析成execute plan后可能会有多个job,但是这些job的并行度是一样的,目前来看,好像还不能对这些job进行并行度的调整,请问一下大家,有什么办法可能调整sql解析后的job的并行度呢?
Reply | Threaded
Open this post in threaded view
|

Re: flink sql job 并行度

Benchao Li
Hi lucas,

据我所知,现在还是不能做到的。
这个可能未来需要用hint来做到控制每个operator的并发度。

lucas.wu <[hidden email]> 于2020年4月29日周三 上午11:16写道:

> Hi all:
> 最近在使用flink sql 做一些计算任务,发现如果一条sql被解析成execute
> plan后可能会有多个job,但是这些job的并行度是一样的,目前来看,好像还不能对这些job进行并行度的调整,请问一下大家,有什么办法可能调整sql解析后的job的并行度呢?



--

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: [hidden email]; [hidden email]