+1 This feature sounds great to me. Allowing users to customize parallelism or infer parallelism for source or sink is indeed an urgent need. For example, In my inner flink jobs (1w+), we need to provide the ability for users to customize parallelism, and the parallelism for Kafka always is the number of partitions.
Look forwart to it ! Best, Hailong Wang 在 2020-10-19 09:53:44，"Jingsong Li" <jingsongl...@gmail.com> 写道： >+1 > >On Fri, Oct 16, 2020 at 2:33 PM Leonard Xu <xbjt...@gmail.com> wrote: > >> +1 >> >> Best, >> Leonard >> >> > 在 2020年10月16日，11:01，Jark Wu <imj...@gmail.com> 写道： >> > >> > +1 >> > >> > On Fri, 16 Oct 2020 at 10:27, admin <17626017...@163.com> wrote: >> > >> >> +1 >> >> >> >>> 2020年10月16日 上午10:05，Danny Chan <yuzhao....@gmail.com> 写道： >> >>> >> >>> +1, nice job ! >> >>> >> >>> Best, >> >>> Danny Chan >> >>> 在 2020年10月15日 +0800 PM8:08，Jingsong Li <jingsongl...@gmail.com>，写道： >> >>>> 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 >> >> until >> >>>> 20th Oct. (72h, exclude weekends), unless there is an objection or not >> >>>> enough votes. >> >>>> >> >>>> [1] >> >>>> >> >> >> https://cwiki.apache.org/confluence/display/FLINK/FLIP-146%3A+Improve+new+TableSource+and+TableSink+interfaces >> >>>> >> >>>> [2] >> >>>> >> >> >> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-146-Improve-new-TableSource-and-TableSink-interfaces-td45161.html >> >>>> >> >>>> Best, >> >>>> Jingsong Lee >> >> >> >> >> >> > >-- >Best, Jingsong Lee
