writer的并行度是根据上游并行度来的 committer的并行度才是1
On Thu, Oct 22, 2020 at 5:22 PM 酷酷的浑蛋 <apach...@163.com> wrote: > 我用flink sql实时写入hive表时发现sink的并行度为1? > 我看了FileSystemTableSink类的226行,确实设置了1,这是为什么呢? 并行度1的写入速度很慢 > > > > -- Best, Jingsong Lee
writer的并行度是根据上游并行度来的 committer的并行度才是1
On Thu, Oct 22, 2020 at 5:22 PM 酷酷的浑蛋 <apach...@163.com> wrote: > 我用flink sql实时写入hive表时发现sink的并行度为1? > 我看了FileSystemTableSink类的226行,确实设置了1,这是为什么呢? 并行度1的写入速度很慢 > > > > -- Best, Jingsong Lee