Re: use of org.apache.flink.yarn.cli.FlinkYarnSessionCli in Flink Sql client

Hi Dipanjan: I just looked through the Flink SQL client code and got the same conclusion as you. Look forward to receiving other comments. Best, Terry Wang > 在 2019年9月22日，下午11:53，Dipanjan Mazumder 写道： > > Hi , > Thanks again for responding on my earlier queries.. > I

Re: Running flink on AWS ECS

Hi, Navneeth, I think both is ok. IMO, run one container with number of slots same as virtual cores may be better for slots can share the Flink Framework and thus reduce memory cost. Best, Terry Wang > 在 2019年9月25日，下午3:26，Navneeth Krishnan 写道： > > Hi All, > > I’m currentl

Re: Flink SQL update-mode set to retract in env file.

-mode will be append only. So if you want enable retract-mode you may need to insert into one kind of RetractStreamTableSink. Hope it helps you ~ Best, Terry Wang > 在 2019年9月26日，下午2:50，srikanth flink 写道： > > How could I configure environment file for Flink SQL, update-mode: retrac

Re: Flink SQL update-mode set to retract in env file.

fka sink function. Your program code is a mixture of table api and dataStream programing not just single Table API. Best, Terry Wang > 在 2019年9月26日，下午5:47，srikanth flink 写道： > > Hi Terry Wang, > > Thanks for quick reply. > > I would like to understand more on your line

Re: Flink SQL GroupBy Excption

Hi, Polarisary~ The reason should be that `uid, device_id` can not be automatically derived from the type of your kafka actionStremt, you should check it and make sure actionStream returns suitable type. Best, Terry Wang > 2019年11月5日 15:11，Polarisary 写道： > > Hi ALL, > I ha

Re: Duplicate tasks for the same query

/flink-docs-master/dev/table/common.html#create-a-tableenvironment <https://ci.apache.org/projects/flink/flink-docs-master/dev/table/common.html#create-a-tableenvironment> Best, Terry Wang > 2019年12月30日 03:07，RKandoji 写道： > > Hi Team, > > I'm doing a POC with flink to

Re: kafka: how to stop consumption temporarily

Hi, I’d like to share my opinion here. It seems that you need adjust the Kafka consumer to have communication each other. When your begin the dump process, you need to notify another CDC-topic consumer to wait idle. Best, Terry Wang > 2020年1月2日 16:49，David Morin 写道： > > Hi, >

Re: [ANNOUNCE] Dian Fu becomes a Flink committer

Congratulations! Best, Terry Wang > 2020年1月17日 14:09，Biao Liu 写道： > > Congrats! > > Thanks, > Biao /'bɪ.aʊ/ > > > > On Fri, 17 Jan 2020 at 13:43, Rui Li <mailto:lirui.fu...@gmail.com>> wrote: > Congratulations Dian, well deserved! &g

Re: [DISCUSS] Deprecate previous Python APIs

+1 for deprecation. It’s very reasonable. > 在 2019年6月12日，下午5:32，Till Rohrmann 写道： > > +1 for deprecation. > > Cheers, > Till > > On Wed, Jun 12, 2019 at 4:31 AM Hequn Cheng > wrote: > +1 on the proposal! > Maintaining only one Python API is helpful for users and c

Re: [ANNOUNCE] Hequn becomes a Flink committer

Congratulations Hequn, well deserved! Best, Terry Wang > 在 2019年8月7日，下午9:16，Oytun Tez 写道： > > Congratulations Hequn! > > --- > Oytun Tez > > M O T A W O R D > The World's Fastest Human Translation Platform. > oy...@motaword.com <mailto:oy...@mot

Re: [ANNOUNCE] Andrey Zagrebin becomes a Flink committer

Congratulations Andrey! Best, Terry Wang > 在 2019年8月15日，下午9:27，Hequn Cheng 写道： > > Congratulations Andrey! > > On Thu, Aug 15, 2019 at 3:30 PM Fabian Hueske <mailto:fhue...@gmail.com>> wrote: > Congrats Andrey! > > Am Do., 15. Aug. 2019 um 07:5

Re: [ANNOUNCE] Zili Chen becomes a Flink committer

Congratulations! Best, Terry Wang > 在 2019年9月11日，下午5:28，Dian Fu 写道： > > Congratulations! > >> 在 2019年9月11日，下午5:26，Jeff Zhang mailto:zjf...@gmail.com>> >> 写道： >> >> Congratulations Zili Chen! >> >> Wesley Peng mailto:wes...@thepeng.e

Re: Task Manager shutdown causing jobs to fail

multiple times that whenever task manager goes down ( e.g. > due to heartbeat issue).. so does all the jobs running on it even when > there are standby task managers availaible with free slots to run them on. > Has anyone faced this issue? > > Regards, > Puneet -- Best Regards, Terry Wang