Re: FlinkSQL1.11.1读取kafka写入Hive(parquet) OOM问题

Wed, 16 Sep 2020 07:25:49 -0700 

感谢回复
目前确实使用keyBy，能把并行度提高，分散数据到多个TaskManager中，但遇见个问题
<http://apache-flink.147419.n8.nabble.com/file/t959/QQ%E6%88%AA%E5%9B%BE20200916221935.png>
 
<http://apache-flink.147419.n8.nabble.com/file/t959/QQ%E6%88%AA%E5%9B%BE20200916222005.png>
 

不知道能不能直接控制Insert语句的并行度



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复