Re: [ANNOUNCE] Apache Flink 1.8.2 released

2019-09-14 Thread Dian Fu
Thanks Jark for being the release manager and the great work! Also thanks to everyone who has contributed to this release. Regards, Dian > 在 2019年9月14日,上午3:24,Till Rohrmann 写道: > > Thanks Jark for being our release manager and thanks to everyone who has > contributed. > > Cheers, > Till >

Re: [ANNOUNCE] Apache Flink 1.8.2 released

2019-09-14 Thread Dian Fu
Thanks Jark for being the release manager and the great work! Also thanks to everyone who has contributed to this release. Regards, Dian > 在 2019年9月14日,上午3:24,Till Rohrmann 写道: > > Thanks Jark for being our release manager and thanks to everyone who has > contributed. > > Cheers, > Till >

Re: Flink kafka producer partitioning scheme

2019-09-14 Thread Eduardo Winpenny Tejedor
Hi Vishwas, Just because a Kafka topic has 40 partitions doesn't mean the 40 partitions need to have messages in them. However, while it is not a requirement it is certainly convenient to populate the 40 partitions for load balancing. What this means if you want to use all partitions is you

Use of loading flink-conf.yaml in Flink-sql client

2019-09-14 Thread Dipanjan Mazumder
Hi,   I was going through the Flink Sql client code and came through a flow where we are loading  flink-conf.yaml in the configuration object as prerequisite for the SQL client to start. I can see that the configuration file has properties pertaining to the Flink cluster. As far as