You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 酷酷的浑蛋 <ap...@163.com> on 2020/10/22 09:22:10 UTC

flink sql 写入hive问题

我用flink sql实时写入hive表时发现sink的并行度为1？ 我看了FileSystemTableSink类的226行，确实设置了1，这是为什么呢？  并行度1的写入速度很慢

Re: flink sql 写入hive问题

Posted by Jingsong Li <ji...@gmail.com>.

writer的并行度是根据上游并行度来的

committer的并行度才是1

On Thu, Oct 22, 2020 at 5:22 PM 酷酷的浑蛋 <ap...@163.com> wrote:

> 我用flink sql实时写入hive表时发现sink的并行度为1？
> 我看了FileSystemTableSink类的226行，确实设置了1，这是为什么呢？  并行度1的写入速度很慢
>
>
>
>

-- 
Best, Jingsong Lee