Hi devs:
Currently,Flink sql does not support source/sink parallelism config.So,it will
result in wasting or lacking resources in some cases.
I think it is necessary to introduce configuration of source/sink parallelism
in sql.
From my side,i have the solution for this feature.Add parallelism con
+1,it’s a good news
> 2020年9月23日 下午6:22,Jingsong Li 写道:
>
> Hi all,
>
> I'd like to start a discussion about improving the new TableSource and
> TableSink interfaces.
>
> Most connectors have been migrated to FLIP-95, but there are still the
> Filesystem and Hive that have not been migrated. T
Hi everyone,
Thanks for the proposal.
In our company,we meet the same situation as @liu shouwei.
We developed some features base on flink.Such as parallelism of sql source/sink
connector, and kafka delay consumer which is adding a flatmap and a keyby
transformation after the source Datastream.
+1
> 2020年10月16日 上午10:05,Danny Chan 写道:
>
> +1, nice job !
>
> Best,
> Danny Chan
> 在 2020年10月15日 +0800 PM8:08,Jingsong Li ,写道:
>> Hi all,
>>
>> I would like to start the vote for FLIP-146 [1], which is discussed and
>> reached consensus in the discussion thread [2]. The vote will be open unti