[jira] [Created] (FLINK-19096) Simplify PersistedStateRegistry state registration methods

2020-08-30 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-19096: --- Summary: Simplify PersistedStateRegistry state registration methods Key: FLINK-19096 URL: https://issues.apache.org/jira/browse/FLINK-19096 Project: Flin

Re: [DISCUSS] FLIP-141: Intra-Slot Managed Memory Sharing

2020-08-30 Thread Xintong Song
Thanks for the feedbacks, @Stephan - There is a push to make as much as possible configurable via the main > configuration, and not only in code. Specifically values for operations and > tuning. > I think it would be more important to have such memory weights in the > config, compared to in

Re: Next Stateful Functions Release

2020-08-30 Thread Tzu-Li (Gordon) Tai
+1, 10 Sept. also sounds like a reasonable feature freeze date considering that most proposed features are already either merged or PR in progress. Cheers, Gordon On Thu, Aug 27, 2020 at 7:55 PM Marta Paes Moreira wrote: > +1 > > The feature set also seems quite in line with user feedback, whic

[jira] [Created] (FLINK-19095) Add expire mode for remote function state TTL

2020-08-30 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-19095: --- Summary: Add expire mode for remote function state TTL Key: FLINK-19095 URL: https://issues.apache.org/jira/browse/FLINK-19095 Project: Flink I

Re: [DISCUSS] FLIP-139: General Python User-Defined Aggregate Function on Table API

2020-08-30 Thread jincheng sun
Hi Wei, Thanks for the discussion! Overall, + 1 for this FLIP. One question is, can the @udaf added by flip-137 be used in General Python UDAF? Would be gread if we can consider it combination with FLIP-137 for design. What do you think? Best, Jincheng Wei Zhong 于2020年8月26日周三 上午11:28写道: > Hi

Re: [DISCUSS] FLIP-137: Support Pandas UDAF in PyFlink

2020-08-30 Thread jincheng sun
Hi Xingbo, Thanks for the discussion! Overall, + 1 for this FLIP. I have two points to add: - We also need to consider how pandas UDAF supports metrics, and whether we need a custom interface for pandas UDAF? - We have added @udaf(), so whether to use ordinary Python UDAF? If not, the addition

[jira] [Created] (FLINK-19094) Revise the description watermark strategy in Flink Table document

2020-08-30 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19094: -- Summary: Revise the description watermark strategy in Flink Table document Key: FLINK-19094 URL: https://issues.apache.org/jira/browse/FLINK-19094 Project: Flink

Re: [DISCUSS] FLIP-141: Intra-Slot Managed Memory Sharing

2020-08-30 Thread Stephan Ewen
Thanks for driving this proposal. A few thoughts on the current design: - There is a push to make as much as possible configurable via the main configuration, and not only in code. Specifically values for operations and tuning. I think it would be more important to have such memory weights i

Re: [ANNOUNCE] New PMC member: Dian Fu

2020-08-30 Thread Zou Dan
Congratulations, Dian! Best, Dan Zou > 2020年8月29日 下午12:38,Yu Li 写道: > > Congratulations, Dian! > > Best Regards, > Yu > > > On Sat, 29 Aug 2020 at 02:10, Thomas Weise wrote: > >> Congratulations! >> >> On Fri, Aug 28, 2020 at 4:51 AM Haibo Sun wrote: >> >>> Congratulations Dian ! >>> >