flink 写hive的并行度只能为1

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

flink 写hive的并行度只能为1

高函

为什么目前flink写hive的并行度只能设置为1呢?
Reply | Threaded
Open this post in threaded view
|

Re: flink 写hive的并行度只能为1

zhuxiaoshang
hi,
并行度为1的是discard sink,实际写数据的是filewriter算子

> 2021年1月20日 下午4:29,高函 <[hidden email]> 写道:
>
>
> 为什么目前flink写hive的并行度只能设置为1呢?