[DISCUSS] Support source/sink parallelism config in Flink sql

2020-09-09 Thread admin
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

Re: [DISCUSS] FLIP-146: Improve new TableSource and TableSink interfaces

2020-09-23 Thread admin
+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

Re: [DISCUSS] FLIP-146: Improve new TableSource and TableSink interfaces

2020-09-25 Thread admin
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.

Re: [VOTE] FLIP-146: Improve new TableSource and TableSink interfaces

2020-10-15 Thread admin
+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