Re: [DISCUSS] FLIP-38 Support python language in flink TableAPI

the development of Table API without UDFs in Flink, and work with the Beam community to promote the abstraction of Beam. What do you think? Regards, Jincheng jincheng sun 于2019年4月17日周三 下午4:01写道： > Hi Stephan, > > Thanks for your suggestion and summarize. :) > > ==> The FL

Re: [DISCUSS] FLIP-38 Support python language in flink TableAPI

Hi Robert, In addition to the questions described by Dian, I also want to know what difficult problems Py4j's solution will encounter in add UDF support, which you mentioned as follows: Using something like Py4j is an easy way to get up an running, especially > for a very faithful API, but the

Re: [DISCUSS] FLIP-38 Support python language in flink TableAPI

Flink* > > - Goal is to not block Flink's Python effort on the long term approach > and the necessary design and evolution of the language-independent DAG. > - Depending on what the outcome of above investigation is, Flink may > initially go with a simple approach to map the Py

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

ee 写道： > > > > Jincheng, Congratulations! > > > > Best, JingsongLee > > > > > > -- > > From:Dawid Wysakowicz > > Send Time:2019年6月25日(星期二) 14:21 > > To:dev > > Subject:Re: [ANN

[DISCUSS] Publish the PyFlink into PyPI

Hi all, With the effort of FLIP-38 [1], the Python Table API(without UDF support for now) will be supported in the coming release-1.9. As described in "Build PyFlink"[2], if users want to use the Python Table API, they can manually install it using the command: "cd flink-python && python3

[RESULT] [VOTE] Release 1.8.1, release candidate #1

I'm happy to announce that we have unanimously approved the 1.8.1 release. There are 5 approving votes, 3 of which are binding: * Hequn * Jark * Jincheng * Gordon * Aljoscha There are no disapproving votes. Thanks everyone!

Re: [VOTE] Release 1.8.1, release candidate #1

dded since 1.8.0 > > - ran the end-to-end tests locally once, and in a loop specifically for > > Kafka tests (to cover FLINK-11987) > > - announcement PR for website looks good! > > > > Cheers, > > Gordon > > > > On Mon, Jul 1, 2019 at 9:02 AM jincheng s

Re: [DISCUSS]Support Upsert mode for Streaming Non-window FlatAggregate

mode to achieve better performance. > > +1 for the `withKeys` proposal. :) > > Best, Hequn > > > On Wed, Jun 26, 2019 at 4:37 PM jincheng sun > wrote: > > > Hi all, > > > > With the continuous efforts from the community, we already supported > > `

Re: [VOTE] Release 1.8.1, release candidate #1

rite hdfs file successfully. > > - Run jobs on YARN(with or without session) successfully > > - Job failover and recovery successfully > > > > PR review > > - Left a minor comment. But I think it is not a blocker, we can just > update > > the PR direc

Re: Dev

Hi Haifeng, Thank you for your willingness to contribute to the Flink community! I've given you contributor permissions! We communicate offline to correct your JIRA id is Spafka. :) Just confirm that your profile is: https://issues.apache.org/jira/secure/ViewProfile.jspa?name=Spafka Please

Re: [DISCUSS]Support Upsert mode for Streaming Non-window FlatAggregate

key, should be latter one > replace previous ones? > > Best, > Kurt > > > On Mon, Jul 1, 2019 at 7:19 AM jincheng sun > wrote: > > > Hi hequn, Thanks for the reply! I think `withKeys` solution is our better > > choice! > > > > > > Heq

[DISCUSS] Flink Python User-Defined Function for Table API

Hi all, The Python Table API(without Python UDF support) has already been supported and will be available in the coming release 1.9. As Python UDF is very important for Python users, we'd like to start the discussion about the Python UDF support in the Python Table API. Aljoscha Krettek, Dian Fu

Re: [DISCUSS] Flink Python User-Defined Function for Table API

//github.com/apache/beam/blob/release-2.14.0/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java > > > > Thomas > > > > > > > > > > > > > > > > On Tue, Aug 13, 2019 at 7:

Re: [ANNOUNCE] Andrey Zagrebin becomes a Flink committer

Congrats Andrey! Very happy to have you onboard :) Best, Jincheng Yu Li 于2019年8月15日周四 上午12:06写道： > Congratulations Andrey! Well deserved! > > Best Regards, > Yu > > > On Wed, 14 Aug 2019 at 17:55, Aleksey Pak wrote: > > > Congratulations, Andrey! > > > > On Wed, Aug 14, 2019 at 4:53 PM Markos

Re: [DISCUSS] Flink Python User-Defined Function for Table API

Hi all, Thanks a lot for your feedback. If there are no more suggestions and comments, I think it's better to initiate a vote to create a FLIP for Apache Flink Python UDFs. What do you think? Best, Jincheng jincheng sun 于2019年8月15日周四 上午12:54写道： > Hi Thomas, > > Thanks for your con

Re: [VOTE] Flink Project Bylaws

+1 Becket Qin 于2019年8月22日 周四16:22写道： > Hi All, so far the votes count as following: > > +1 (Binding): 13 (Aljoscha, Fabian, Kurt, Till, Timo, Max, Stephan, > Gordon, Robert, Ufuk, Chesnay, Shaoxuan, Henry) > +0 (Binding): 1 (Thomas) > > +1 (Non-Binding): 10 (Hequn, Vino, Piotr, Dawid, Xintong,

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

Tue, Jul 23, 2019 at 4:48 PM Hugo Louro > > >> wrote: > > >> > > > > > >> > > >> +1 > > >> > > >> > > >> > > >> > On Jul 23, 2019, at 6:15 AM, Till Rohrmann < > > trohrm...@apache.org > > >> >

Re: [DISCUSS] Flink Python User-Defined Function for Table API

> > 在 2019年8月26日，上午9:53，jincheng sun 写道： > > > > Thanks for your feedback Hequn & Dian. > > > > Dian, I am glad to see that you want help to create the FLIP! > > Everyone will have first time, and I am very willing to help you complete > > your first FLIP

[DISCUSS] Releasing Flink 1.8.2

Hi Flink devs, It has been nearly 2 months since the 1.8.1 released. So, what do you think about releasing Flink 1.8.2 soon? We already have some blocker and critical fixes in the release-1.8 branch: [Blocker] - FLINK-13159 java.lang.ClassNotFoundException when restore job - FLINK-10368

Re: [ANNOUNCE] Apache Flink-shaded 8.0 released

Thanks a lot Chesnay and to the community for making this release possible ! Cheers, Jincheng Chesnay Schepler 于2019年8月30日周五 下午6:56写道： > The Apache Flink community is very happy to announce the release of > Apache Flink-shaded 8.0. > > The flink-shaded project contains a number of shaded

Re: [DISCUSS] Flink Python User-Defined Function for Table API

; > > > > On Mon, Aug 26, 2019 at 8:05 PM Dian Fu wrote: > > > >> Hi Jincheng, > >> > >> Thanks! It works. > >> > >> Thanks, > >> Dian > >> > >>> 在 2019年8月27日，上午10:55，jincheng sun 写道： > >>> >

Re: [VOTE] FLIP-58: Flink Python User-Defined Function for Table API

Hi Dian, +1, Thanks for your great job! Best, Jincheng Dian Fu 于2019年8月28日周三 上午11:04写道： > Hi all, > > I'd like to start a voting thread for FLIP-58 [1] since that we have > reached an agreement on the design in the discussion thread [2], > > This vote will be open for at least 72 hours.

Re: [DISCUSS] Releasing Flink 1.8.2

blocker > https://issues.apache.org/jira/browse/FLINK-13940. > It is not a regression but it can result to data loss. > > I think I can have a quick fix by tomorrow. > > Cheers, > Kostas > > On Mon, Sep 2, 2019 at 12:01 PM jincheng sun > wrote: > > > > Than

Re: [DISCUSS] Flink Python User-Defined Function for Table API

e to set this method. So it must be > final in UserDefinedFunction similar to getKind(). > > 5. Function characteristics: If UserDefinedFunction is defined in > Python, why is it not used in your example in FLIP-58. You could you > extend the example to show how to specify these attributes in

Re: [DISCUSS] Releasing Flink 1.8.2

> > Best, > > > Jark > > > > > > On Tue, 3 Sep 2019 at 21:33, Kostas Kloudas > wrote: > > > > > > > Thanks for waiting! > > > > > > > > A fix for FLINK-13940 has been merged on 1.8, 1.9 and the master > unde

Re: [DISCUSS] Flink Python User-Defined Function for Table API

f you don't mind. As I haven't created a FLIP before, > > it will be great if you could help on this. :) > > > > Regards, > > Dian > > > > > 在 2019年8月22日，下午11:41，jincheng sun 写道： > > > > > > Hi all, > > > > > > Thanks a lot for your feedback.

Re: [DISCUSS] Releasing Flink 1.8.2

equn > > > > > > > > > On Fri, Aug 30, 2019 at 6:31 PM Maximilian Michels > > wrote: > > > > > > > Hi Jincheng, > > > > > > > > +1 I would be for a 1.8.2 release such that we can fix the problems > > with > >

Re: [DISCUSS] Flink Python User-Defined Function for Table API

> Is this correct? If yes, I would suggest to title the FLIP as "Flink > Python > > User-Defined Function" or "Flink Python User-Defined Function for Table". > > > > Regards, > > Shaoxuan > > > > > > On Wed, Aug 28, 2019 at 12:2

Re: [DISCUSS] Releasing Flink 1.8.2

-13586 for this > >> release. It would be good to compensate for the backward incompatible > >> change to ClosureCleaner that was introduced in 1.8.1, which affects > >> downstream dependencies. > >> > >> Thanks, > >> Thomas > >> &

Re: [DISCUSS] Flink Python User-Defined Function for Table API

ied to Flink SQL. > > Is this correct? If yes, I would suggest to title the FLIP as "Flink > Python > > User-Defined Function" or "Flink Python User-Defined Function for Table". > > > > Regards, > > Shaoxuan > > > > > > On Wed, Aug

Re: [DISCUSS] Flink Python User-Defined Function for Table API

ble.functions.ScalarFunction#getKind` we don't allow > users to override this property. And I think we should do something similar > for the getLanguage property. > > > > Thanks, > > Timo > > > > On 03.09.19 15:01, jincheng sun wrote: > >> Hi Timo

Re: [DISCUSS] Flink Python User-Defined Function for Table API

don't allow > users to override this property. And I think we should do something similar > for the getLanguage property. > > > > Thanks, > > Timo > > > > On 03.09.19 15:01, jincheng sun wrote: > >> Hi Timo, > >> > >> Thanks for the

Re: [ANNOUNCE] Apache Flink 1.8.2 released

Thanks for being the release manager and the great work Jark :) Also thanks to the community making this release possible! Best, Jincheng Jark Wu 于2019年9月13日周五 下午10:07写道： > Hi, > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.8.2, which is the second

Re: [VOTE] Release 1.8.2, release candidate #1

+1 (binding) - checked signatures [SUCCESS] - built from source without tests [SUCCESS] - ran some tests in IDE [SUCCESS] - start local cluster and submit word count example [SUCCESS] - announcement PR for website looks good! (I have left a few comments) Best, Jincheng Jark Wu 于2019年9月6日周五

Re: [VOTE] FLIP-58: Flink Python User-Defined Function for Table API

; > > > > > > > > > On Fri, 30 Aug 2019 at 10:04, Xingbo Huang > > > wrote: > > > > > > > > > > > >> Hi Dian, > > > > > >> > > > > > >> +1, > > > > > >> Thanks a

Re: [DISCUSS] Flink Python User-Defined Function for Table API

es right away, but I’m also fine with > using the old method names for now. > > Best, > Aljoscha > > > On 5. Sep 2019, at 12:40, jincheng sun wrote: > > > > Hi Aljoscha, > > > > Thanks for your comments! > > > > Regarding to the FLIP scope

Re: [DISCUSS] Flink Python User-Defined Function for Table API

https://cwiki.apache.org/confluence/display/FLINK/FLIP-64%3A+Support+for+Temporary+Objects+in+Table+module > > > > On 5. Sep 2019, at 05:01, jincheng sun wrote: > > > > Hi Aljoscha, > > > > That's a good points, so far, most of the code will live in flink-py

[ANNOUNCE] Hequn becomes a Flink committer

Hi everyone, I'm very happy to announce that Hequn accepted the offer of the Flink PMC to become a committer of the Flink project. Hequn has been contributing to Flink for many years, mainly working on SQL/Table API features. He's also frequently helping out on the user mailing lists and helping

Re: [DISCUSS] Publish the PyFlink into PyPI

9, 2019 at 9:24 AM jincheng sun > wrote: > > > Yes Till, I think you are correct that we should make sure that the > > published Flink Python API cannot be arbitrarily deleted. > > > > So, It seems that our current consensus is: > > > > 1. Should we re pu

[VOTE] Publish the PyFlink into PyPI

Hi all, Publish the PyFlink into PyPI is very important for our user, Please vote on the following proposal: 1. Create PyPI Project for Apache Flink Python API, named: "apache-flink" 2. Release one binary with the default Scala version same with flink default config. 3. Create an account, named

Re: [DISCUSS] Publish the PyFlink into PyPI

or of option #2. > > I guess that the PMC would need to give the credentials to the release > manager for option #1. Hence, the PMC could also add the release manager as > a maintainer which makes sure that only the PMC can delete artifacts. > > Cheers, > Till > > On Wed, Jul

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

+1 Robert Metzger 于2019年7月23日周二 下午4:01写道： > +1 > > On Mon, Jul 22, 2019 at 10:27 AM Biao Liu wrote: > > > +1, make sense to me. > > Mailing list seems to be a more "community" way. > > > > Timo Walther 于2019年7月22日周一 下午4:06写道： > > > > > +1 sounds good to inform people about instabilities or

Re: [DISCUSS] Flink project bylaws

Hi Becket, Thanks for the proposal. Regarding the vote of FLIP, preferably at least includes a PMC vote. Because FLIP is usually a big change or affects the user's interface changes. What do you think? (I leave the comment in the wiki.) Best, Jincheng Dawid Wysakowicz 于2019年7月17日周三 下午9:12写道：

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket and welcome onboard as a committer! Best, Jincheng Dawid Wysakowicz 于2019年7月18日周四 下午5:10写道： > Congratulations Becket! Good to have you onboard! > > On 18/07/2019 10:56, Till Rohrmann wrote: > > Congrats Becket! > > > > On Thu, Jul 18, 2019 at 10:52 AM Jeff Zhang wrote: > > > >>

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

Thanks for bring up the discussion, Wei. Overall the design doc looks good. I have left a few comments. BTW: Dependency Management is very important for Python UDFs, welcome anyone left your suggestions! Best, Jincheng Wei Zhong 于2019年9月26日周四 上午11:59写道： > Hi everyone, > > In FLIP-58 [1] we

Re: [DISCUSS] Releasing Flink 1.9.1

Good Job Jark, Looking forward the first RC of 1.9.1. And I would like to give you a hand at the last stage when the RC is finished.(If you need) Best, Jincheng Jark Wu 于2019年9月25日周三 下午8:04写道： > Hi all, > > I am here to update the progress of the issue that needs to be tracked: > > -

Re: [DISCUSS] Releasing Flink 1.9.1

t; > >>>> > Hi all, > > > > >>>> > > > > > >>>> > I am here to update the progress of the issues that need to be > > > > >>>> tracked: > > > > >>>> > > > > > >

Re: [DISCUSS] Releasing Flink 1.9.1

gt; >>>> > - FLINK-13708 (as discussed with Jeff offline, postpone it to > 1.9.2) > > >>>> > > > >>>> > Great thanks to all of you for helping fix and reviewing! All the > > >>>> blocker > > >>>> > issues for 1

Re: Flink 1.8.1 release tag missing?

Thanks Bekir Oguz and Chesnay! Sorry for that, I forgot push the tag, I've pushed the tag to the repo now. https://github.com/apache/flink/tree/release-1.8.1 Thanks again, and I'm very sorry for my negligence has caused confusion in your use. Thanks, Jincheng Bekir Oguz 于2019年7月10日周三

Re: [DISCUSS] Releasing Flink 1.8.3

can be the release manager of 1.8.3 or work > with > > > you > > > > together @Jincheng? > > > > It's always exciting to help the community as much as possible. > > > > > > > > Best, Hequn > > > > > > > > On Sat, Nov 9,

Re: [DISCUSS] PyFlink User-Defined Function Resource Management

Hi all, +1， Thanks for bring up this discussion Dian! The Resource Management is very important for PyFlink UDF. So, It's great if anyone can add more comments or inputs in the design doc or feedback in ML. :) Best, Jincheng Dian Fu 于2019年11月5日周二 上午11:32写道： > Hi everyone, > > In FLIP-58[1]

[DISCUSS] Releasing Flink 1.8.3

Hi Flink devs, It has been more than 2 months since the 1.8.2 released. So, What do you think about releasing Flink 1.8.3 soon? We already have many important bug fixes in the release-1.8 branch (29 resolved issues). Most notable fixes are: - FLINK-14010 Dispatcher & JobManagers don't give up

Re: [VOTE] Accept Stateful Functions into Apache Flink

big +1 (binding) Andrey Zagrebin 于2019年10月30日 周三23:45写道： > sorry, my +1 was non-binding, confused that it was not a committer vote but > PMC. > > On Wed, Oct 30, 2019 at 4:43 PM Chesnay Schepler > wrote: > > > +1 (binding) > > > > On 30/10/2019 15:25, Vasiliki Kalavri wrote: > > > +1 (binding)

Re: [DISCUSS] Releasing Flink 1.8.3

arious jackson dependencies to eliminate a few > security vulnerabilities. > > On 09/11/2019 05:10, jincheng sun wrote: > > Hi Flink devs, > > > > It has been more than 2 months since the 1.8.2 released. So, What do you > > think about releasing Flink 1.8.3 soon? >

Re: [DISCUSS] Expose or setup a secur...@flink.apache.org mailing list for security report and discussion

Hi Dian, Thanks a lot for bringing up this discussion. This is very important for Flink community! I think setup a security mailing list for Flink is pretty nice although ` secur...@apache.org` can be used and the report will be forwarded to Flink private mailing list if there is no project

Re: [VOTE] FLIP-83: Flink End-to-end Performance Testing Framework

+1 (binding) OpenInx 于2019年11月18日周一 下午12:09写道： > +1 (non-binding) > > On Mon, Nov 18, 2019 at 11:54 AM aihua li wrote: > > > +1 (non-binding) > > > > Thanks Yu Li for driving on this. > > > > > 在 2019年11月15日，下午8:10，Yu Li 写道： > > > > > > Hi All, > > > > > > I would like to start the vote

[ANNOUNCE] Jark Wu is now part of the Flink PMC

Hi all, On behalf of the Flink PMC, I'm happy to announce that Jark Wu is now part of the Apache Flink Project Management Committee (PMC). Jark has been a committer since February 2017. He has been very active on Flink's Table API / SQL component, as well as frequently helping manage/verify/vote

Re: [DISCUSS] Improve the Pyflink command line options (Adjustment to FLIP-78)

Thanks for bringup this discussion Wei! I think this is very important for Flink User, we should contains this changes in Flink 1.10. +1 for the optimization from the perspective of user convenience and the unified use of Flink command line parameters. Best, Jincheng Wei Zhong 于2019年12月2日周一

Re: [DISCUSS] Improve the Pyflink command line options (Adjustment to FLIP-78)

html/rfc3986#section-3.5 > > > >> 在 2019年12月3日，22:02，Aljoscha Krettek 写道： > >> > >> Hi, > >> > >> Yes, I think it’s a good idea to make the options uniform. Using ‘#’ as > a separator for options that take two values seems a bit strange to me, did &g

Re: [DISCUSS] Drop Kafka 0.8/0.9

+1 for drop it, and Thanks for bring up this discussion Chesnay! Best, Jincheng Jark Wu 于2019年12月5日周四 上午10:19写道： > +1 for dropping, also cc'ed user mailing list. > > > Best, > Jark > > On Thu, 5 Dec 2019 at 03:39, Konstantin Knauf > wrote: > > > Hi Chesnay, > > > > +1 for dropping. I have

Re: [VOTE] FLIP-27 - Refactor Source Interface

+1 (binding), and looking forward to seeing the new interface in the master. Best, Jincheng Becket Qin 于2019年12月5日周四 上午8:05写道： > Hi all, > > I would like to start the vote for FLIP-27 which proposes to introduce a > new Source connector interface to address a few problems in the existing >

Re: [VOTE] Release 1.8.3, release candidate #3

+1 (binding) - checked signatures [SUCCESS] - built from source without tests [SUCCESS] - run some tests in IDE [SUCCESS] - start local cluster and submit word count example [SUCCESS] - announcement PR for website looks good! (I have left a few comments) Best, Jincheng Hequn Cheng

Re: [ANNOUNCE] Zhu Zhu becomes a Flink committer

Congrats ZhuZhu and welcome on board! Best, Jincheng Jark Wu 于2019年12月14日周六 上午9:55写道： > Congratulations, Zhu Zhu! > > Best, > Jark > > On Sat, 14 Dec 2019 at 08:20, Yangze Guo wrote: > > > Congrats, ZhuZhu! > > > > Bowen Li 于 2019年12月14日周六 上午5:37写道： > > > > > Congrats! > > > > > > On Fri,

Re: [ANNOUNCE] Apache Flink 1.8.3 released

Thanks for being the release manager and the great work Hequn :) Also thanks to the community making this release possible! Best, Jincheng Jark Wu 于2019年12月12日周四 下午3:23写道： > Thanks Hequn for helping out this release and being the release manager. > Great work! > > Best, > Jark > > On Thu, 12

Re: [VOTE] Improve the Pyflink command line options (Adjustment to FLIP-78)

+1 (binding) Best, Jincheng Dian Fu 于2019年12月5日周四 上午11:14写道： > +1 (non-binding) > > Regards, > Dian > > > 在 2019年12月5日，上午11:11，Jark Wu 写道： > > > > +1 (binding) > > > > Best, > > Jark > > > > On Thu, 5 Dec 2019 at 10:45, Wei Zhong wrote: > > > >> Hi all, > >> > >> According to our previous

Re: [VOTE] FLIP-88: PyFlink User-Defined Function Resource Management

+1（binding) Best, Jincheng Jingsong Li 于2019年12月3日周二 下午7:30写道： > +1 (non-binding) > > Best, > Jingsong Lee > > On Mon, Dec 2, 2019 at 5:30 PM Dian Fu wrote: > > > Hi Jingsong, > > > > It's fine. :) Appreciated the comments! > > > > I have replied you in the discussion thread as I also think

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

> some feedback and vote on this. > > > > Best, > > Wei > > > >> 在 2019年10月25日，09:33，jincheng sun 写道： > >> > >> Hi Thomas, > >> > >> Thanks for your explanation. I understand your original intention. I > will &

Re: [VOTE] Release 1.9.1, release candidate #1

o > > you > > > >> need > > > >>> modify fix version? > > > >>> https://issues.apache.org/jira/browse/FLINK-14328 > > > >>> https://issues.apache.org/jira/browse/FLINK-14327 > > > >>> https://issues.apache.org/jira/browse/FLINK-

Re: [VOTE] FLIP-65: New type inference for Table API UDFs

+1(binding) Best, Jincheng Jark Wu 于2019年10月21日周一 下午4:55写道： > +1 (binding) > > Best, > Jark > > > 在 2019年10月21日，16:52，Aljoscha Krettek 写道： > > > > +1 (binding) > > > > Aljoscha > > > >> On 21. Oct 2019, at 10:50, Timo Walther wrote: > >> > >> Hi everyone, > >> > >> I would like to start a

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

> >> Thomas > >> > >> > >> On Mon, Oct 14, 2019 at 8:09 AM Jeff Zhang wrote: > >> > >>> +1 > >>> > >>> Hequn Cheng 于2019年10月14日周一 下午10:55写道： > >>> > >>>> +1 > >>>> > >&

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

n. > > +1 for the proposal otherwise > > Thomas > > > On Mon, Oct 21, 2019 at 8:40 PM jincheng sun > wrote: > > > Hi Thomas, > > > > Thanks for sharing your thoughts. I think improve and solve the > limitations > > of the Beam artifact sta

Re: [ANNOUNCE] Becket Qin joins the Flink PMC

Congratulations Becket. Best, Jincheng Rui Li 于2019年10月29日周二 上午11:37写道： > Congrats Becket! > > On Tue, Oct 29, 2019 at 11:20 AM Leonard Xu wrote: > > > Congratulations! Becket. > > > > Best, > > Leonard Xu > > > > > On 2019年10月29日, at 上午11:00, Zhenghua Gao wrote: > > > > > > Congratulations,

Re: [VOTE] Publish the PyFlink into PyPI

votes, 4 of which are binding: - Dian Fu - Stephan Ewen - Jeff Zhang - vino yang - Till Rohrmann - Yu Li - Jark Wu - Biao Liu - Hequn Cheng - Aljoscha Krettek - Jincheng Sun (I’m hereby +1’ing) There were no -1 votes. Thanks everyone! Best, Jincheng

Re: [DISCUSS] How to prepare the Python environment of PyFlink release in the current Flink release process

Hi, Thanks for bringing up the discussion Dian. +1 for the #1. Hi Jeff, this changes is for the PyFlink release, i.e.,The release manager should build the release package for Pyflink, and prepare the python environment during the building. Since 1.10 we only support python 3.5+, so it will throw

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

good > (better?) option for artifact staging even for the Beam Flink runner? > > If so, can the implementation you propose be compatible with the Beam > artifact staging service so that it can be plugged into the Beam Flink > runner? > > Thanks, > Thomas > > > On Mon, Oc

Re: [VOTE] Setup a secur...@flink.apache.org mailing list

+1 Dian Fu 于2019年11月21日周四 下午4:11写道： > Hi all, > > According to our previous discussion in [1], I'd like to bring up a vote > to set up a secur...@flink.apache.org mailing list. > > The vote will be open for at least 72 hours (excluding weekend). I'll try > to close it by 2019-11-26 18:00 UTC,

Re: [DISCUSS] Releasing Flink 1.8.3

e, I'm not concerned about such kind of ugprades >>>> being more >>>> >>> > >> common >>>> >>> > >>>>>>> in the future. >>>> >>> > >>>>>>> >>>> &

Re: [VOTE] Setup a secur...@flink.apache.org mailing list

; > the categories we have listed in our bylaws. Are committers votes > > binding or just PMCs'? (Personally I think it should be PMCs') Is this a > > binding vote or just an informational vote? > > > > Best, > > > > Dawid > > > > O

Re: Confluence permission for FLIP creation

I have given you edit permission, could you please re-login and check it. :) Danny Chan 于2019年9月24日周二 上午11:31写道： > Hi all, > > As communicated in an email thread, I'm proposing to support computed > column in Flink SQL . I have a draft design doc that I'd like to convert it > to a FLIP. Thus,

Re: Confluence permission for FLIP creation

I have given you edit permission, could you please re-login and check it. :) Zhenghua Gao 于2019年9月24日周二 下午8:13写道： > Hi all, > > I'm proposing to support view in Flink SQL and I have a initial design doc > which i want to convert to a FLIP. It would be great if anyone who can > grant me the

Re: [DISCUSS] Drop Python 2 support for 1.10

Hi Dian， Thanks for bringing this discussion! In Flink 1.9 we only add Python Table API mapping to Java Table API(without Python UDFs), there no special requirements for Python version, so we add python 2,7 support. But for Flink 1.10, we add the Python UDFs support, i.e., user will add more

Re: [VOTE] Release 1.9.1, release candidate #1

I think we should create the new RC when we find the blocker issues. We can looking forward the other check result, we can add the fix of FLINK-14315 in to 1.9.1 only we find the blockers. Best, Jincheng Till Rohrmann 于2019年10月8日周二 下午8:20写道： > FLINK-14315 has been merged into the release-1.9

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

; > >> Hi Wei, > >> > >> Thanks a lot for bringing up this discussion. Python dependency > management is very important for Python users. I have left a few comments > on the design doc. > >> > >> Thanks, > >> Dian > >> > >>>

Re: [PROPOSAL] Contribute Stateful Functions to Apache Flink

Hi Stephan, bit +1 for adding this great features to Apache Flink. Regarding where we should place it, put it into Flink core repository or create a separate repository? I prefer put it into main repository and looking forward the more detail discussion for this decision. Best, Jincheng

Re: [DISCUSS] Drop Python 2 support for 1.10

Hi Dian, I think it's better to bring up the VOTE for this proposal. Then push this forward.:) Thanks, Jincheng Timo Walther 于2019年10月10日周四 下午8:07写道： > I also heard from other companies that upgrading to Python 3 is in > progress for data teams. > > +1 for simplifying the code base with

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

uld be great if you can grant me > the write access to Confluence :). My Confluence ID is zhongwei. > > Thanks, > Wei Zhong > > > 在 2019年10月12日，17:41，jincheng sun 写道： > > Hi, > > + 1 to bring up the VOTE and create the FLIP. > > Best, > Jincheng > >

Re: [VOTE] Drop Python 2 support for 1.10

+1 Dian Fu 于2019年10月14日周一 下午1:21写道： > Hi all, > > I would like to start the vote for "Drop Python 2 support for 1.10", which > is discussed and reached a consensus in the discussion thread[1]. > > The vote will be open for at least 72 hours. Unless there is an objection, > I will try to close

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

+1 Wei Zhong 于2019年10月12日周六 下午8:41写道： > Hi all, > > I would like to start the vote for FLIP-78[1] which is discussed and > reached consensus in the discussion thread[2]. > > The vote will be open for at least 72 hours. I'll try to close it by > 2019-10-16 18:00 UTC, unless there is an objection

Re: [DISCUSS] Releasing Flink 1.9.2

Thanks for bring up the discussion Hequn. I would like to give you a hand at the last stage when the RC is finished.(If you need) :) Best, Jincheng Best, Jincheng @sunjincheng121 Hequn Cheng 于2019年12月18日周三 下午3:44写道： > Hi everyone, > > It has already been

Re: [DISCUSS] What parts of the Python API should we focus on next ?

gt; On Wed, Dec 18, 2019 at 19:05 jincheng sun > wrote: > >> Also CC user-zh. >> >> Best, >> Jincheng >> >> >> jincheng sun 于2019年12月19日周四 上午10:20写道： >> >>> Hi folks, >>> >>> As release-1.10 is under feature-fre

[DISCUSS] What parts of the Python API should we focus on next ?

Hi folks, As release-1.10 is under feature-freeze(The stateless Python UDF is already supported), it is time for us to plan the features of PyFlink for the next release. To make sure the features supported in PyFlink are the mostly demanded for the community, we'd like to get more people

Re: [DISCUSS] What parts of the Python API should we focus on next ?

Also CC user-zh. Best, Jincheng jincheng sun 于2019年12月19日周四 上午10:20写道： > Hi folks, > > As release-1.10 is under feature-freeze(The stateless Python UDF is > already supported), it is time for us to plan the features of PyFlink for > the next release. > > To make sure t

Re: [DISCUSS] Release flink-shaded 10.0

+1 for the new flink-shaded release. Thanks for driving this Chesnay! Best, Jincheng Jeff Zhang 于2020年2月8日周六 下午12:52写道： > +1, Thanks for driving this Chesnay > > > Yu Li 于2020年2月8日周六 上午11:53写道： > > > +1 for starting a new flink-shaded release. > > > > Thanks for bringing this up Chesnay. >

Re: [VOTE] Release Flink Python API(PyFlink) 1.9.2 to PyPI, release candidate #0

Hi all, I hereby cancel this vote! If there is no new negative feedback, I will prepare a new RC and bring up a new VOTE thread soon. Best, Jincheng jincheng sun 于2020年2月6日周四 下午6:25写道： > Hi Chesnay, > > Thanks a lot for sharing your thoughts. > > >> this is

Re: [VOTE] Release Flink Python API(PyFlink) 1.9.2 to PyPI, release candidate #1

l > and no exception. > - Try a word count example in IDE with Python 2.7.15 and Python 3.7.5, run > well and no exception. > > Best, > Wei > > > 在 2020年2月10日，19:12，jincheng sun 写道： > > Hi everyone, > > Please review and vote on the release candidate #1 f

Re: [VOTE] Release 1.10.0, release candidate #3

+1 (binding) - Download the source code [SUCCESS] - Build the source release with Scala 2.12 and Scala 2.11 [SUCCESS] - Checked/verified signatures and hashes [SUCCESS] - Pip install PyFlink by `pip3 install apache-flink-1.10.0.tar.gz` [SUCCESS] - Run a word_count.py both in command line and

Re: [ANNOUNCE] Jingsong Lee becomes a Flink committer

Congratulations Jingsong! Best, Jincheng Zhu Zhu 于2020年2月24日周一 上午11:55写道： > Congratulations Jingsong! > > Thanks, > Zhu Zhu > > Fabian Hueske 于2020年2月22日周六 上午1:30写道： > >> Congrats Jingsong! >> >> Cheers, Fabian >> >> Am Fr., 21. Feb. 2020 um 17:49 Uhr schrieb Rong Rong > >: >> >> >

Re: [VOTE] FLIP-103: Better TM/JM Log Display

+1(binding) Thank you for driving this Yadong! Best, Jincheng Yangze Guo 于2020年2月21日周五 下午3:08写道： > +1 (non-binding) > > It will make debugging more convenient and hence improve usability. > > Best, > Yangze Guo > > On Fri, Feb 21, 2020 at 2:50 PM Yang Wang wrote: > > > > Hi Jark, > > > > The

Re: [VOTE] Release 1.9.2, release candidate #1

+1 (binding) - Release notes looks good. - Check end-to-end tests passed. - Signatures and hash are correct. - All artifacts have been deployed to the maven central repository. - Started a local Flink cluster and ran the streaming WordCount example. - Verified web UI and log output, nothing

Re: [VOTE] Release Flink Python API(PyFlink) 1.9.2 to PyPI, release candidate #0

nor that it is a python/PyPi-specific release > > - Development status classifier seems incorrect as it is set to "Planning" > > > On 05/02/2020 09:03, jincheng sun wrote: > > Hi Wei, > > > > Thanks for your vote and I appreciate that you kindly help to take th

<    1   2   3   4   >