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 le

[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 setup.py

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

ce 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 sun

[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!

[ANNOUNCE] Apache Flink 1.8.1 released

Hi, The Apache Flink community is very happy to announce the release of Apache Flink 1.8.1, which is the first bugfix release for the Apache Flink 1.8 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streamin

Re: [ANNOUNCE] Apache Flink 1.8.1 released

s to Gorden and the community making this release possible! > > Best, Hequn > > On Wed, Jul 3, 2019 at 9:40 AM jincheng sun > wrote: > >> Hi, >> >> The Apache Flink community is very happy to announce the release of >> Apache Flink 1.8.1, which is the fi

Re: Application for contributor permission

Hi wudi， Thank you for your willingness to contribute to the Flink community，just confirm, does the follows page is your profile? https://issues.apache.org/jira/secure/ViewProfile.jspa?name=wuyanzu Best, Jincheng 吴迪 于2019年7月4日周四 上午9:52写道： > Hi , > > I want to contribute to Apache Flink, and m

Re: Application for contributor permission

7;s mine. > > > -邮件原件- > 发件人: jincheng sun [mailto:sunjincheng...@gmail.com] > 发送时间: 2019年7月4日 10:26 > 收件人: dev > 主题: Re: Application for contributor permission > > Hi wudi， > > Thank you for your willingness to contribute to the Flink community，just > co

Re: [DISCUSS] Publish the PyFlink into PyPI

ould be > to make this part of our normal release process. There will be _one_ source > release on dist.apache.org encompassing everything, and a separate python > of focused source release that we push to PyPi. The LICENSE and NOTICE > contained in the python source release must al

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

7;m not sure about the idea of this does not involve semantic changes. To > > me, it sounds like > > we are doing another nested aggregation inside the table > > which TableAggregateFunction emits. > > > > Maybe I'm not familiar with this function enough,

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

nt >>>> types, >>>> one will no key, one with key information. So the developer of the >>>> UDTAGG >>>> should choose which type of this function should be. In this case, >>>> my question would be, why don't we have explicit informatio

Re: Apply for being a contributor

Hi WangHW, Welcome to the Flink community! I gave you contributor permissions for Jira. Best, Jincheng 疯琴 <35023...@qq.com> 于2019年7月8日周一 上午9:17写道： > Hi, > > > I want to contribute to Apache Flink. > Would you please give me the contributor permission? > My JIRA ID is WangHW, my full

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日周三 上午12:50写道

Re: [ANNOUNCE] Rong Rong becomes a Flink committer

Congratulations Rong, Well deserved! Cheers, Jincheng Dian Fu 于2019年7月12日周五 上午9:06写道： > > Congrats Rong! > > > 在 2019年7月12日，上午8:47，Chen YuZhao 写道： > > congratulations! > > 获取 Outlook for iOS > > -- > *发件人:* Rong Rong > *发送时间:* 星期五, 七月 12, 20

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] 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 oth

Re: [DISCUSS] Publish the PyFlink into PyPI

ring, I would be fine with whatever option. > The > >>> PMC doesn't own it (it is an initiative by some community members), > but the > >>> PMC needs to ensure trademark compliance, so slight preference for > option > >>> #1 (PMC would have means to co

Re: [DISCUSS] Publish the PyFlink into PyPI

would be in favor 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 > &g

[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

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

[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

[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 a

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

ttps://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

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: [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, Yu

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 you

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

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

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

t; > > On 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

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

n > > > > > > 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. Unless

[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 'Kerberi

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 depend

Re: [DISCUSS] Releasing Flink 1.8.2

st, Hequn > > > > > > > > > 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 > > wit

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

applied 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,

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

be applied 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 > > > > > >

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: > > > > Thanks fo

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

sers should not be able 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 sp

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 > under > >

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

nk.table.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: > >&g

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

etKind` 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, > >> > >> Tha

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

; [1] > 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 l

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

l names 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

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: [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日周五 下午8:

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 bugf

Re: Re: Re: [VOTE] Accept Flink CDC into Apache Flink

+1 (binding) Best, Jincheng Sun Zhu Zhu 于2024年1月12日周五 14:11写道： > +1 (binding) > > Thanks, > Zhu > > Hangxiang Yu 于2024年1月11日周四 14:26写道： > > > +1 (non-binding) > > > > On Thu, Jan 11, 2024 at 11:19 AM Xuannan Su > wrote: > > > &

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

There is a blocker issue: https://issues.apache.org/jira/browse/FLINK-15937 Best, Jincheng Jeff Zhang 于2020年2月6日周四 下午3:09写道： > -1, I just found one critical issue > https://issues.apache.org/jira/browse/FLINK-15935 > This ticket means user unable to use watermark in sql if he specify both > f

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

iptive as it neither says that it is a > binary 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 vot

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 no

Re: [DISCUSS] Support Python ML Pipeline API

Hi Hequn, Thanks for bring up this discussion. +1 for add Python ML Pipeline API, even though the Java pipeline API may change. I would like to suggest create a FLIP for this API changes. :) Best, Jincheng Hequn Cheng 于2020年2月5日周三 下午5:24写道： > Hi everyone, > > FLIP-39[1] rebuilds the Flink M

Re: [DISCUSS] Support scalar vectorized Python UDF in PyFlink

Hi Dian, Thanks for bring up this discussion. This is very important for the ecological of PyFlink. Add support Pandas greatly enriches the available UDF library of PyFlink and greatly improves the usability of PyFlink! +1 for Support scalar vectorized Python UDF. I think we should to create a F

Re: [DISCUSS] Support scalar vectorized Python UDF in PyFlink

improve the performance and also the usability of > > user-defined functions (UDFs) in Python. > > One little suggestion: maybe it would be nice if we can add some > > performance explanation in the document? (I just very curious:)) > > > > +1 to create a FLIP for this

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

Hi everyone, Please review and vote on the release candidate #1 for the PyFlink version 1.9.2, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * the official Apa

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 PyCha

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 Flink Python API(PyFlink) 1.9.2 to PyPI, release candidate #1

gt;>> > >>> > On Tue, Feb 11, 2020 at 12:17 PM Dian Fu >>> wrote: >>> > >>> > > +1 (non-binding) >>> > > >>> > > - Verified the signature and checksum >>> > > - Pip installed the package successfully: pip install

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

Hi everyone, I'm happy to announce that we have unanimously approved this release. There are 7 approving votes, 3 of which are binding: * Wei Zhong * Jincheng Sun(binding) * Dian Fu * Hequn Cheng * Jark Wu (binding) * Jiangjie (Becket) Qin (binding) * Xingbo Huang There are no disappr

Re: [VOTE] Support scalar vectorized Python UDF in PyFlink

+1 (binding) Best, Jincheng Dian Fu 于2020年2月12日周三 下午1:31写道： > Hi all, > > I'd like to start the vote of FLIP-97[1] which is discussed and reached > consensus in the discussion thread[2]. > > The vote will be open for at least 72 hours. Unless there is an objection, > I will try to close it by

[ANNOUNCE] Apache Flink Python API(PyFlink) 1.9.2 released

Hi everyone, The Apache Flink community is very happy to announce the release of Apache Flink Python API(PyFlink) 1.9.2, which is the first release to PyPI for the Apache Flink Python API 1.9 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, alw

Re: Cwiki edit access

Hi Lining, Could you please information about why you need page access authority， and which page you want edit? Best, Jincheng lining jing 于2020年2月14日周五 上午11:09写道： > Hi, I would like to be able to edit pages in the Confluence Flink space. > Can > someone give me access, please? > > Thanks > --

Re: Cwiki edit access

Hi Lining, Could you please add more information about why you need page access authority， and which page you want to edit? Best, Jincheng lining jing 于2020年2月14日周五 上午11:09写道： > Hi, I would like to be able to edit pages in the Confluence Flink space. > Can > someone give me access, please? >

Re: [VOTE] Support Python ML Pipeline API

+1(binding) Best, Jincheng Hequn Cheng 于2020年2月14日周五 上午9:45写道： > Hi everyone, > > I'd like to start the vote of FLIP-96[1] which is discussed and reached > consensus in the discussion thread[2]. > The vote will be open for at least 72 hours. Unless there is an objection, > I will try to close

Re: Cwiki edit access

it. > > jincheng sun 于2020年2月14日周五 上午11:43写道： > > > Hi Lining, > > > > Could you please add more information about why you need page access > > authority， and which page you want to edit? > > > > Best, > > Jincheng > > > > > > lin

Re: [VOTE] Release flink-shaded 10.0, release candidate #3

+1 (binding) With simple check; - Downloaded the source and built successfully - Verified the signature and checksum Best, Jincheng Zhijiang 于2020年2月16日周日 上午12:11写道： > +1 (non-binding) > > - Checked the release notes > - Downloaded the source and built successfully > - Verified the signat

Re: [ANNOUNCE] New Documentation Style Guide

Thanks for this great job Aljoscha! Best, Jincheng Yu Li 于2020年2月17日周一 下午6:42写道： > I think the guide itself is a great example of the new style! Thanks for > driving this, Aljoscha! > > Best Regards, > Yu > > > On Mon, 17 Feb 2020 at 16:44, Becket Qin wrote: > > > The guideline is very pract

Re: [DISCUSS] Improvements on FLIP Process

Hi all, Thanks for bring up the discussion @Hequn! I agree with some concerns raised above, however, I would like to give my +1 for the proposal and I would like to share my thoughts: If I understand correctly, the proposal doesn’t encourage people to discuss in the google doc, the first step of

Re: [ANNOUNCE] Apache Flink-shaded 10.0 released

Thanks a lot for the release Chesnay! And thanks to everyone who make this release possible! Best, Jincheng Chesnay Schepler 于2020年2月19日周三 上午12:45写道： > The Apache Flink community is very happy to announce the release of > Apache Flink-shaded 10.0. > > The flink-shaded project contains a number

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 > >: >> >> > Congratula

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 G

Re: [DISCUSS] Releasing Flink 1.10.1

Thanks for bring up the discussion Yu. I would like to give you a hand at the last stage when the RC is finished.(If you need) :) Best, Jincheng Yu Li 于2020年3月10日周二 下午5:49写道： > Hi All, > > It has been almost one month since we released Flink 1.10.0. We already > have more than 40 resolved im

Re: [DISCUSS] FLIP-112: Support User-Defined Metrics for Python UDF

Hi Hequn, +1, thank you for this discussion, and metrics are very important for monitoring the running state of Python UDF. Best, Jincheng Hequn Cheng 于2020年3月12日周四 下午11:39写道： > @Dian Fu Thanks a lot for the advice. The FLIP > page has been updated. > > Best, > Hequn > > On Thu, Mar 12, 202

Re: [VOTE] FLIP-112: Support User-Defined Metrics for Python UDF

+1 Best, Jincheng Hequn Cheng 于2020年3月16日周一 上午10:01写道： > Hi everyone, > > I'd like to start the vote of FLIP-112[1] which is discussed and reached > consensus in the discussion thread[2]. > The vote will be open for at least 72 hours. Unless there is an objection, > I will try to close it by

Re: [VOTE] FLIP-106: Support Python UDF in SQL Function DDL

+1 Best, Jincheng Wei Zhong 于2020年3月13日周五 下午9:04写道： > Hi all, > > I would like to start the vote for FLIP-106[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 > 2020-03-18 14:00 UTC, unless ther

Re: [DISCUSS] FLIP-114: Support Python UDF in SQL Client

Hi Wei, +1, Thanks for this discussion which is crucial for SQL users to use PyFlink. Would be great to bring up the VOTE thread. Best, Jincheng Wei Zhong 于2020年3月30日周一 下午2:38写道： > Hi everyone, > > Are there more comments about this FLIP? If not, I would like to bring up > the VOTE. > > Best,

Re: [VOTE] FLIP-114: Support Python UDF in SQL Client

+1(binding) Best, Jincheng Xingbo Huang 于2020年4月1日周三 下午5:36写道： > Hi Wei, > > +1 (non-binding) > Thanks a lot for driving this. > > Best, > Xingbo > > Wei Zhong 于2020年3月31日周二 上午10:34写道： > > > Hi all, > > > > I would like to start the vote for FLIP-114[1] which is discussed and > > reached con

Re: [DISCUSS] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame

a in > > >> Python community. PyFlink table is Flink’s representation of the > tabular > > >> data in Python language. It would be nice to provide the functionality > > to > > >> convert between the PyFlink table and Pandas dataframe in PyFlink > Tabl

Re: [DISCUSS] FLIP-121: Support Cython Optimizing Python User Defined Function

;> Python UDTF will be supported in the coming release of 1.11. In release > >> 1.10, we focused on supporting UDF features and did not make many > >> optimizations in terms of performance. Although we have made a lot of > >> optimizations in master[2], Cython can further greatly imp

Re: [DISCUSS] Releasing Flink 1.9.3

Hi Dian, Thanks for bring up the discussion. I would like to give you a hand at the last stage when the RC is finished. :) Best, Jincheng Dian Fu 于2020年4月10日周五 上午11:08写道： > Hi all, > > It has been more than two months since we released Flink 1.9.2. There are > already 36 improvements/bugfix

Re: [VOTE] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame

+1(binding) Best, Jincheng Xingbo Huang 于2020年4月9日周四 下午8:27写道： > Hi Dian, > > +1 (non-binding) > Thanks a lot for driving this. > > Best, > Xingbo > > Dian Fu 于2020年4月8日周三 上午10:03写道： > > > Hi all, > > > > I'd like to start the vote for FLIP-120[1] which is discussed and reached > > consensus

Re: [VOTE] FLIP-121: Support Cython Optimizing Python User Defined Function

+1(binding) Best, Jincheng Dian Fu 于2020年4月8日周三 上午9:59写道： > +1 (binding) > > > 在 2020年4月8日，上午9:53，Xingbo Huang 写道： > > > > Hi all, > > I would like to start the vote for FLIP-121[1], which is discussed and > > reached a consensus in the discussion thread[2]. > > > > The vote will be open for

Re: [DISCUSS] Releasing Flink 1.10.1

>>> > > > > > > > >>> having 1.10.2 in the near future. > > > >> >>>> > > > > > > > >>> > > > >>

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations and welcome on board Hequn! Best, Jincheng Zhijiang 于2020年4月19日周日 下午10:47写道： > Congratulations, Hequn! > > Best, > Zhijiang > > > -- > From:Yun Gao > Send Time:2020 Apr. 19 (Sun.) 21:53 > To:dev > Subject:Re: [A

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

+1（binding） with the check of built form the source and run some test case. BTW： I added you(dianfu) as a PyPI maintainer of Apache Flink. Best, Jincheng Dawid Wysakowicz 于2020年4月23日周四 下午7:43写道： > +1 (binding) > > - verified checksums and signatures > > - verified no binary artifacts in sour

Re: [ANNOUNCE] Apache Flink 1.9.3 released

Thanks for your great job, Dian! Best, Jincheng Hequn Cheng 于2020年4月25日周六 下午8:30写道： > @Dian, thanks a lot for the release and for being the release manager. > Also thanks to everyone who made this release possible! > > Best, > Hequn > > On Sat, Apr 25, 2020 at 7:57 PM Dian Fu wrote: > >> Hi e

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, it

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 writ

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 hav

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: > > - FLINK-14010

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: [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] 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 pyth

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 br

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 Jingso

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

t; >> > >> 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: [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 option

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 > >

  1   2   3   4   >