Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
关于flink sql并行度问题的请教
Classic
List
Threaded
♦
♦
Locked
1 message
me
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
关于flink sql并行度问题的请教
我的代码中使用flinksql,本机idea中测试没有问题,放到集群上跑之后,占用了全部40个slots,并且并行度为114,程序也一直卡着没有输出,是一个加入了时间窗口的flink sql
我再代码中全局设置了,dataStreamEnv.setParallelism(4)
dataStreamEnv.setMaxParallelism(4)
但是感觉完全不起作用,请问怎么去限制flink sql的并行度?
Free forum by Nabble
Edit this page