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

2019-08-29 Thread Xingbo Huang
Hi Dian, +1, Thanks a lot for driving this. Best, Xingbo > 在 2019年8月30日,上午9:39,Wei Zhong 写道: > > Hi Dian, > > +1 non-binding > Thanks for driving this! > > Best, Wei > >> 在 2019年8月29日,09:25,Hequn Cheng 写道: >> >> Hi Dian, >> >> +1 >> Thanks a lot for driving this. >> >> Best, Hequn >> >

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

2023-05-22 Thread Xingbo Huang
+1 (binding) - verify signatures and checksums - verify python wheel package contents - pip install apache-flink-libraries and apache-flink wheel packages - run example flink/flink-python/pyflink/examples/table/basic_operations.py with Python 3.10 - reviewed release blog post Best, Xingbo Yuxin

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

2023-05-22 Thread Xingbo Huang
+1 (binding) - verify signatures and checksums - verify python wheel package contents - pip install apache-flink-libraries and apache-flink wheel packages - run example flink/flink-python/pyflink/examples/table/basic_operations.py with Python 3.7 - reviewed release blog post Best, Xingbo Xintong

Re: [VOTE] Apache Flink ML Release 2.3.0, release candidate #1

2023-06-29 Thread Xingbo Huang
+1 (binding) - Verified the checksums and GPG files. - Reviewed the website PR. - Check the Python package apache-flink-ml-2.3.0.tar.gz Best, Xingbo Dian Fu 于2023年6月29日周四 19:46写道: > +1 (binding) > > - Verified the checksums and signatures. > - The website PR LGTM > > Regards, > Dian > > On Thu

Re: [DISCUSS] Drop python 3.7 support in 1.19

2023-09-05 Thread Xingbo Huang
Hi Gabor, Thanks for bringing this up. In my opinion, it is a bit aggressive to directly drop Python 3.7 in 1.19. Python 3.7 is still used a lot[1], and as far as I know, many Pyflink users are still using python 3.7 as their default interpreter. I prefer to deprecate Python 3.7 in 1.19 just like

Re: [DISCUSS] Drop python 3.7 support in 1.19

2023-09-06 Thread Xingbo Huang
r from now. >> Making this change can increase the adoption instantly if we enable new >> platforms. >> >> Cheers, >> Gyula >> >> On Wed, Sep 6, 2023 at 4:46 AM Xingbo Huang wrote: >> >> > Hi Gabor, >> > >> > Thanks for b

Re: [DISCUSS] Drop python 3.7 support in 1.19

2023-09-06 Thread Xingbo Huang
8+. > > There is already a PR which is under development: > https://github.com/apache/flink/pull/23359 > This fills all the mentioned gaps: local test/development/test execution on > ARM CPUs + the previously mentioned 3+ years not actively supported python > eliminated. > >

Re: [DISCUSS] Externalized Python Connector Release/Dependency Process

2024-01-09 Thread Xingbo Huang
Hi Danny, +1 Thanks a lot for investigating this. Let me share the current code management and release situation of pyflink here. I hope it will be helpful to you. Since Flink 1.13, release managers need to release two python packages to pypi, apache-flink[1] and apache-flink-libraries[2]. apach

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

2024-01-09 Thread Xingbo Huang
+1 (binding) Best, Xingbo Dian Fu 于2024年1月10日周三 11:35写道: > +1 (binding) > > Regards, > Dian > > On Wed, Jan 10, 2024 at 5:09 AM Sharath wrote: > > > > +1 (non-binding) > > > > Best, > > Sharath > > > > On Tue, Jan 9, 2024 at 1:02 PM Venkata Sanath Muppalla < > sanath...@gmail.com> > > wrote: >

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

2020-02-12 Thread Xingbo Huang
+1 (non-binding) - Install the PyFlink by `pip install` [SUCCESS] - Run word_count.py [SUCCESS] Thanks, Xingbo Becket Qin 于2020年2月12日周三 下午2:28写道: > +1 (binding) > > - verified signature > - Ran word count example successfully. > > Thanks, > > Jiangjie (Becket) Qin > > On Wed, Feb 12, 2020 at 1

Re: [ANNOUNCE] Apache Flink-shaded 10.0 released

2020-02-20 Thread Xingbo Huang
Thanks a lot Chesnay and all contributes to this release. Best, Xingbo Hequn Cheng 于2020年2月20日周四 下午8:17写道: > Thanks a lot for the release Chesnay! > Also thanks to everyone who contributes to this release! > > Best, Hequn > > On Thu, Feb 20, 2020 at 11:11 AM Yu Li wrote: > > > Thanks Chesnay a

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

2020-02-20 Thread Xingbo Huang
Thanks a lot for the release. Great Work, Jincheng! Also thanks to participants who contribute to this release. Best, Xingbo Till Rohrmann 于2020年2月18日周二 下午11:40写道: > Thanks for updating the 1.9.2 release wrt Flink's Python API Jincheng! > > Cheers, > Till > > On Thu, Feb 13, 2020 at 12:25 PM H

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

2020-02-20 Thread Xingbo Huang
ight documentation? > > Thanks! > -chad > > > On Thu, Feb 20, 2020 at 5:39 AM Xingbo Huang wrote: > >> Thanks a lot for the release. >> Great Work, Jincheng! >> Also thanks to participants who contribute to this release. >> >> Best, >> Xingbo

Re: [ANNOUNCE] Jingsong Lee becomes a Flink committer

2020-02-20 Thread Xingbo Huang
Congratulations Jingsong! Well deserved. Best, Xingbo wenlong.lwl 于2020年2月21日周五 上午11:43写道: > Congrats Jingsong! > > On Fri, 21 Feb 2020 at 11:41, Dian Fu wrote: > > > Congrats Jingsong! > > > > > 在 2020年2月21日,上午11:39,Jark Wu 写道: > > > > > > Congratulations Jingsong! Well deserved. > > > > > >

[Reminder] Service Unavailable in JIRA

2020-03-03 Thread Xingbo Huang
Hi, all developers. Currently Service Unavailable in JIRA. Not only the flink community, other communities also cannot access JIRA Best, Xingbo

Re: [DISCUSS] FLIP-108: Add GPU support in Flink

2020-03-03 Thread Xingbo Huang
Thanks a lot for the FLIP, Yangze. There is no doubt that GPU resource management support will greatly facilitate the development of AI-related applications by PyFlink users. I have only one comment about this wiki: Regarding the names of several GPU configurations, I think it is better to delet

Re: Flink dev blog

2020-03-04 Thread Xingbo Huang
Thanks a for this proposal. As a new contributor to Flink, it would be very helpful to have such blogs for us to understand the future of Flink and get involved BTW, I have a question whether the dev blog needs a template like FLIP. Of course, There is no doubt that dev blogs do not need to be a

Re: [DISCUSS] Disable "Squash and merge" button for Flink repository on GitHub

2020-03-05 Thread Xingbo Huang
Hi Jark, Thanks for bringing up this discussion. Good catch. Agree that we can disable "Squash and merge"(also the other buttons) for now. There is a guideline on how to do that in https://help.github.com/en/github/administering-a-repository/configuring-commit-squashing-for-pull-requests . Best,

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

2020-03-09 Thread Xingbo Huang
Hi Wei, Thanks a lot for the proposal. Best, Xingbo godfrey he 于2020年3月9日周一 下午10:24写道: > Hi Wei, thanks for the proposal. > > I think it's better to give two more examples, one is how to use python UDF > in SQL, another is how to start sql-client.sh with full python > dependencies. > > Best, >

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

2020-03-09 Thread Xingbo Huang
Hi Godfrey, thanks for your suggestion. I have added two examples how to use python UDF in SQL and how to start sql-client.sh with full python dependencies In FLIP. Best, Xingo godfrey he 于2020年3月9日周一 下午10:24写道: > Hi Wei, thanks for the proposal. > > I think it's better to give two more example

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

2020-03-10 Thread Xingbo Huang
Hi Hequn, thanks for drafting the FLIP and kicking off the discussion. +1 for this feature. I think this feature will be extremely convenient for PyFlink users. Best, Xingbo Hequn Cheng 于2020年3月9日周一 上午11:32写道: > Hi everyone, > > FLIP-58 adds the support for Python UDFs, but user-defined metric

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

2020-03-13 Thread Xingbo Huang
Hi Wei, Thanks a lot for drafting the FLIP and kicking off the discussion. Big +1 for this feature. This feature will greatly facilitate PyFlink users to use Python UDF in SQL scenarios. Best, Xingbo Hequn Cheng 于2020年3月13日周五 下午5:10写道: > Big +1 on this feature! It would be great to extend the u

Re: Hope to be Flink contributor

2020-03-19 Thread Xingbo Huang
Hi, Welcome you to join the Flink community. Currently, you do not need a JIRA permission. Only committers can assign a Jira ticket. For how to participate in community contributions, you can refer to the official contribution guide[1] and correspoinding Chinese doc[2] Best, Xingbo [1] https://

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

2020-03-31 Thread Xingbo Huang
Hi everyone, I would like to start a discussion thread on "Support Cython Optimizing Python User Defined Function" Scalar Python UDF FLIP-58[1] has already been supported in release 1.10 and Python UDTF will be supported in the coming release of 1.11. In release 1.10, we focused on supporting UDF

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

2020-04-01 Thread Xingbo Huang
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 consensus in the discussion thread[2]. > > The vote will be open for at least 72 hours. I'll try

Re: [ANNOUNCE] New Committers and PMC member

2020-04-01 Thread Xingbo Huang
Congratulations to all of you. Best, Xingbo Rui Li 于2020年4月1日周三 下午5:45写道: > Congrats to you all! > > On Wed, Apr 1, 2020 at 5:32 PM Jeff Zhang wrote: > > > Congratulations to all of you Well deserved. > > > > Tzu-Li (Gordon) Tai 于2020年4月1日周三 下午5:28写道: > > > > > Konstantin, Dawid, and Zhijiang

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

2020-04-07 Thread Xingbo Huang
t; > 在 2020年4月7日,下午12:38,Robert Metzger 写道: > > > > > > Thank you for posting the FLIP. > > > > > > The proposed integration with Azure Pipelines looks good to me. > > > > > > On Tue, Mar 31, 2020 at 1:23 PM Xingbo Huang > wrote: &g

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

2020-04-07 Thread 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 at least 72h, unless there is an objection or not enough votes. Best, Xingbo [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-121%3A

Re: Configuring autolinks to Flink JIRA ticket in github repos

2020-04-09 Thread Xingbo Huang
Thanks Yun, Good Work. It is very convenient to link to JIRA from corresponding PR currently. Best, Xingbo Hequn Cheng 于2020年4月9日周四 下午8:16写道: > It’s much more convenient now. Thanks you! > > > On Apr 9, 2020, at 8:01 PM, Aljoscha Krettek > wrote: > > > > That is very nice! Thanks for taking c

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

2020-04-09 Thread Xingbo Huang
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 in the discussion thread[2]. > > The vote will be open for at least 72 hours unless there is

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

2020-04-13 Thread Xingbo Huang
ng) > > > > Best, > > Jincheng > > > > > > > > Dian Fu 于2020年4月8日周三 上午9:59写道: > > > > > +1 (binding) > > > > > > > 在 2020年4月8日,上午9:53,Xingbo Huang 写道: > > > > > > > > Hi all, > > > > I would li

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

2020-04-13 Thread Xingbo Huang
Hi all, The voting time for FLIP-121[1] has passed. I'm closing the vote now. There 3 + 1votes, 3 of which are binding: - Dian (binding) - Jincheng (binding) - Hequn (binding) There are no disapproving votes. Thus, FLIP-121 has been accepted. Thanks a lot for everyone for joining this discussi

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

2020-04-17 Thread Xingbo Huang
Congratulations! Best, Xingbo tison 于2020年4月17日周五 下午6:43写道: > Congrats! > > Best, > tison. > > > Yun Tang 于2020年4月17日周五 下午6:40写道: > > > Congratulations , Hequn > > > > Best > > Yun Tang > > > > From: Guowei Ma > > Sent: Friday, April 17, 2020 18:27 > > To: dev

Re: [ANNOUNCE] Dian Fu becomes a Flink committer

2020-01-16 Thread Xingbo Huang
Congratulations, Dian. Well deserved! Best, Xingbo Wei Zhong 于2020年1月16日周四 下午6:13写道: > Congrats Dian Fu! Well deserved! > > Best, > Wei > > 在 2020年1月16日,18:10,Hequn Cheng 写道: > > Congratulations, Dian. > Well deserved! > > Best, Hequn > > On Thu, Jan 16, 2020 at 6:08 PM Leonard Xu wrote: > >

[DISCUSS] Support User-Defined Table Function in PyFlink

2020-02-02 Thread Xingbo Huang
Hi all, The scalar Python UDF has already been supported in coming release of 1.10, we’d like to introduce Python UDTF now. FLIP-58[1] has already introduced some content about Python UDTF. However, the implementation details are still not touched. I have drafted a design doc[2]. It includes the f

Re: [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience.

2020-02-03 Thread Xingbo Huang
Hi Jincheng, Thanks for driving this. +1 for this proposal. Compared to building from source, downloading directly from PyPI will greatly save the development cost of Python users. Best, Xingbo Wei Zhong 于2020年2月4日周二 下午12:43写道: > Hi Jincheng, > > Thanks for bring up this discussion! > > +1

Re: [DISCUSS] Support User-Defined Table Function in PyFlink

2020-02-04 Thread Xingbo Huang
d in FLIP-58. So, I think is better to create the JIRA and open the > PR, then more detail can be reviewed. :) > > Best, > Jincheng > > > > Xingbo Huang 于2020年2月3日周一 下午3:02写道: > > > Hi all, > > > > The scalar Python UDF has already been supported in coming

Re: [DISCUSS] Support User-Defined Table Function in PyFlink

2020-02-04 Thread Xingbo Huang
> > mentioned in FLIP-58. So, I think is better to create the JIRA and open > the > > PR, then more detail can be reviewed. :) > > > > Best, > > Jincheng > > > > > > > > Xingbo Huang 于2020年2月3日周一 下午3:02写道: > > > > > Hi all, >

Apply for Contributor Permission

2019-05-05 Thread Xingbo Huang
Hi guys, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA username is hxbks2ks. Thanks.

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

2020-09-02 Thread Xingbo Huang
reuse the `class aggregate function (user defined > function)` interface in FLIP-139, and the core logic of Pandas UDAF users > is written in the `accumulate` method. In this way, we can unify the > interface semantics of all UDAF. > > What do you think? > > Best, > Jincheng &

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

2020-09-03 Thread Xingbo Huang
> Dian > > > 在 2020年9月3日,下午5:22,jincheng sun 写道: > > > > Thank you! looking forward to the voting :) > > > > Best, > > Jincheng > > > > > > Xingbo Huang 于2020年9月3日周四 下午2:39写道: > > > >> Hi Jincheng, > >> > >>

[VOTE] FLIP-137: Support Pandas UDAF in PyFlink

2020-09-03 Thread Xingbo Huang
Hi all, I would like to start the vote for FLIP-137[1], which is discussed and reached a consensus in the discussion thread[2]. The vote will be open for at least 72h, unless there is an objection or not enough votes. Best, Xingbo [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-137%3A

Re: 退订dev

2020-09-06 Thread Xingbo Huang
Hi Please send an email to dev-unsubscr...@flink.apache.org for unsubscribing. You can read more information[1] here [1] https://flink.apache.org/community.html Best, Xingbo 高丽丽 于2020年9月7日周一 上午10:58写道: > > unsubscribe flink apache

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

2020-09-07 Thread Xingbo Huang
Hi, +1 (non-binding) Best, Xingbo Wei Zhong 于2020年9月7日周一 下午2:37写道: > Hi all, > > I would like to start the vote for FLIP-139[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-09-10 07:00 UT

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

2020-09-08 Thread Xingbo Huang
) > > > > > > > > > 在 2020年9月7日,下午2:38,Wei Zhong 写道: > > > > > > > > > > +1 (non-binding) > > > > > > > > > >> 在 2020年9月7日,10:00,Dian Fu 写道: > > > > >> > > > > >> +1 > > > >

[RESULT][VOTE] FLIP-137: Support Pandas UDAF in PyFlink

2020-09-08 Thread Xingbo Huang
Hi all, The voting time for FLIP-137[1] has passed. I'm closing the vote now. There 6 + 1 votes, 4 of which are binding: - Dian (binding) - Jincheng (binding) - Hequn (binding) - Zhu Zhu (binding) - Wei (non-binding) - Shuiqiang (non-binding) There are no disapproving votes. Thus, FLIP-137 has

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

2020-09-14 Thread Xingbo Huang
+1 (non-binding) Checks: - Pip install PyFlink from wheel packages with Python 3.5,3.6 and 3.7 in Mac and Linux. - Test Python UDF/Pandas UDF - Test from_pandas/to_pandas Best, Xingbo Fabian Paul 于2020年9月14日周一 下午8:46写道: > +1 (non-binding) > > Checks: > > - Verified signature > - Built from so

Re: [ANNOUNCE] New Apache Flink Committer - Niels Basjes

2020-09-14 Thread Xingbo Huang
Congratulations! Best, Xingbo Dian Fu 于2020年9月14日周一 下午8:06写道: > Congratulations! > > Regards, > Dian > > > 在 2020年9月14日,下午7:45,Zhu Zhu 写道: > > > > Congratulations! > > > > Thanks, > > Zhu > > > > Matt Wang 于2020年9月14日周一 下午5:22写道: > > > >> Congratulations, Niels! > >> > >> > >> -- > >> > >> Be

Re: [ANNOUNCE] New Apache Flink Committer - Arvid Heise

2020-09-15 Thread Xingbo Huang
Congratulations! Best, Xingbo Igal Shilman 于2020年9月15日周二 下午5:44写道: > Congrats Arvid! > > On Tue, Sep 15, 2020 at 11:12 AM David Anderson > wrote: > > > Congratulations, Arvid! Well deserved. > > > > Best, > > David > > > > On Tue, Sep 15, 2020 at 10:23 AM Paul Lam wrote: > > > > > Congrats, A

Re: [ANNOUNCE] New Apache Flink Committer - Igal Shilman

2020-09-15 Thread Xingbo Huang
Congratulations! Best, Xingbo Matt Wang 于2020年9月15日周二 下午5:44写道: > Congrats Igal! > > > -- > > Best, > Matt Wang > > > On 09/15/2020 17:00,Dawid Wysakowicz wrote: > Congrats Igal. It's good to have you among committers! :) > > Best, > > Dawid > > On 15/09/2020 10:14, Tzu-Li (Gordon) Tai wrote: >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He

2020-09-16 Thread Xingbo Huang
Congratulations, well deserved. Best, Xingbo Xintong Song 于2020年9月16日周三 下午4:59写道: > Congratulations, Godfrey~! > > Thank you~ > > Xintong Song > > > > On Wed, Sep 16, 2020 at 3:28 PM Yu Li wrote: > > > Congrats and welcome, Godfrey! > > > > Best Regards, > > Yu > > > > > > On Wed, 16 Sep 2020

Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-06 Thread Xingbo Huang
Congratulations Zhu Zhu Best, Xingbo Leonard Xu 于2020年10月6日周二 下午4:50写道: > Congratulations Zhu Zhu! > > Best > Leonard > > > 在 2020年10月6日,14:52,Yuan Mei 写道: > > > > Congrats, Zhu Zhu :-) > > > > Best > > Yuan > > > > On Tue, Oct 6, 2020 at 1:54 PM Dian Fu wrote: > > > >> Congratulations Zhu Zh

Re: [ANNOUNCE] New Apache Flink Committer - Congxian Qiu

2020-10-29 Thread Xingbo Huang
Congratulations Congxian. Best, Xingbo Dian Fu 于2020年10月29日周四 下午3:05写道: > Congratulations Congxian! > > Regards, > Dian > > > 在 2020年10月29日,下午2:35,Yangze Guo 写道: > > > > Congratulations! > > > > Best, > > Yangze Guo > > > > On Thu, Oct 29, 2020 at 2:31 PM Jark Wu wrote: > >> > >> Congrats Con

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-18 Thread Xingbo Huang
Big +1 for java-based e2e tests. Currently PyFlink related tests each take ~15minutes in bash e2e tests because we are using a secured YARN cluster which is the only convenient way of starting a YARN cluster in the bash e2e tests. I think if we migrate these tests to the java-based testing framewor

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-27 Thread Xingbo Huang
docker image improvement, I think we should be more cautious as >>> developers at China might suffer with the network issue, or at least we >>> should ensure or find some guides to speed up the image downloading. >>> >>> Best >>> Yun Tang >>> ___

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

2020-12-03 Thread Xingbo Huang
+1 (non-binding) Checks: 1. verified checksums and signatures 2. build Flink with Scala 2.11 3. pip install pyflink in MacOS/CentOS under py35,py36,py37,py38 4. test Pandas UDAF/General UDAF/Python DataStream MapFunction 5. start standalone cluster and submit a python udf job. 6. verified NOTICE/L

Re: [DISCUSS] Make SQL docs Blink only

2020-12-08 Thread Xingbo Huang
+1 This is a very good proposal.In release-1.12, many newly added features are only supported on the blink planner. For example, the newly added features of PyFlnk in FLIP-137[1] and FLIP-139[2] are only available on the blink planner. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-13

Re: Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Xingbo Huang
Congratulations! Thanks Dian and Robert for the great work! And thanks everyone who makes the release possible ! Best, Xingbo hailongwang <18868816...@163.com> 于2020年12月10日周四 下午8:42写道: > > > Congratulations! Thanks Dian and Robert for the great work! > > > Best, > Hailong > At 2020-12-10 19:35:4

Re: [DISCUSS] FLIP-153: Support state access in Python DataStream API

2020-12-13 Thread Xingbo Huang
Thanks Shuiqiang for starting this discussion. Big +1 for this feature. State access support can further improve the functionality of our existing Python DataStream. I have 2 comments regarding to the design doc: a) I think that `StateDescriptor` needs to hold the variable `typeInfo` instead of

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

2020-12-15 Thread Xingbo Huang
+1 (non-binding) - verified checksums and signatures - build Flink with Scala 2.11 - pip install pyflink in MacOS under py37 - test pyflink shell - test cover FLINK-18836 and FLINK-19675 Best, Xingbo Tzu-Li (Gordon) Tai 于2020年12月16日周三 下午12:29写道: > +1 (binding) > > - Verified signature and hash

Re: [DISCUSS] Enforce common opinionated coding style using Spotless

2020-12-16 Thread Xingbo Huang
+1 asap. Spotless can greatly help us save the time of fixing checkstyle errors. Best, Xingbo Kostas Kloudas 于2020年12月17日周四 上午4:14写道: > +1 asap from my side as well. > > On Wed, Dec 16, 2020 at 8:04 PM Arvid Heise wrote: > > > > +1 asap. > > > > On Wed, Dec 16, 2020 at 7:44 PM Robert Metzger

Re: [DISCUSS] Releasing Apache Flink 1.12.1

2020-12-20 Thread Xingbo Huang
Hi Xintong, Thanks a lot for driving this. I'd like to bring one more issue to your attention: https://issues.apache.org/jira/browse/FLINK-20389. This issue occurs quite frequently. Arvid and Kezhu have done some investigations of this issue and it may indicate a bug of the new Source API. It wou

Re: [VOTE] Apache Flink Stateful Functions 2.2.2, release candidate #2

2020-12-23 Thread Xingbo Huang
+1 (non-binding) - Verify checksums and GPG files - Verify that the source archives do not contains any binaries - Build the source with Maven to ensure all source files have Apache headers (JDK8) Command: mvn clean install -Papache-release - Run e2e tests (JDK8) - Check that all POM files, Docker

Re: [ANNOUNCE] Apache Flink Stateful Functions 2.2.2 released

2021-01-03 Thread Xingbo Huang
@Gordon Thanks a lot for the release and for being the release manager. And thanks to everyone who made this release possible! Best, Xingbo Till Rohrmann 于2021年1月3日周日 下午8:31写道: > Great to hear! Thanks a lot to everyone who helped make this release > possible. > > Cheers, > Till > > On Sat, Jan

Re: [VOTE] FLIP-153: Support state access in Python DataStream API

2021-01-05 Thread Xingbo Huang
+1 (non-binding) Best, Xingbo Dian Fu 于2021年1月6日周三 下午1:38写道: > +1 (binding) > > > 在 2021年1月6日,下午1:12,Shuiqiang Chen 写道: > > > > Hi devs, > > > > The discussion of the FLIP-153 [1] seems has reached a consensus through > > the mailing thread [2]. I would like to start a vote for it. > > > > The

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

2021-01-09 Thread Xingbo Huang
Hi Xintong, FLINK-20309[1] has been reopened which is about unaligned checkpoint. I'm not sure if this should be a blocker of 1.12.1. I'm cc @Piotr who can provide more information about this issue. [1] https://issues.apache.org/jira/browse/FLINK-20309 Best, Xingbo > 2021年1月10日 上午9:23,Xintong

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

2021-01-11 Thread Xingbo Huang
e what additionally causes this issue and > > cannot give an estimate about the impact of the fix nor the time needed > to > > fix it. It may also only be a test issue. > > > > I wouldn't block on this fix. It has also been present in 1.12.0 already. > > >

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Xingbo Huang
Congratulations, Danny! Best, Xingbo Dian Fu 于2021年1月12日周二 下午5:48写道: > Congratulations, Danny! > > Regards, > Dian > > > 在 2021年1月12日,下午5:40,Till Rohrmann 写道: > > > > Congrats and welcome Danny! > > > > Cheers, > > Till > > > > On Tue, Jan 12, 2021 at 10:09 AM Dawid Wysakowicz < > dwysakow...@

Re: [DISCUSS] Releasing Apache Flink 1.10.3

2021-01-13 Thread Xingbo Huang
Thanks for starting this discussion, Matthias. +1 for releasing 1.10.3 as it contains a number of important fixes. Best, Xingbo Xintong Song 于2021年1月13日周三 下午3:46写道: > Thanks for bringing this up, Matthias. > > Per the "Update Policy for old releases" [1], normally we do not release > 1.10.x af

Re: [DISCUSS] Extending the feature freezing date of Flink 1.17

2023-01-03 Thread Xingbo Huang
+1 for extending the freeze date to Jan 31st Best, Xingbo Jingsong Li 于2023年1月3日周二 17:58写道: > +1 > > On Tue, Jan 3, 2023 at 4:40 PM Matthias Pohl > wrote: > > > > +1 for extending to Jan 31 > > > > On Tue, Jan 3, 2023 at 8:33 AM Yu Li wrote: > > > > > +1 for the proposal (extending the 1.17 f

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

2023-03-14 Thread Xingbo Huang
+1 (binding) - checked signatures and checksums of binaries - reviewed release blog post - verify python wheel package contents - run the examples from Python Table API tutorial Thanks for preparing this rc! Xingbo Samrat Deb 于2023年3月14日周二 10:16写道: > +1 (non binding) > > - checked AWS SDKv2

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

2023-03-21 Thread Xingbo Huang
+1 (binding) - verify signatures and checksums - verify python wheel package contents - pip install apache-flink-libraries and apache-flink wheel packages - run example flink/flink-python/pyflink/examples/table/basic_operations.py with Python 3.10 - reviewed release note PR Best, Xingbo Sergey N

Re: [VOTE] Apache Flink ML Release 2.2.0, release candidate #2

2023-04-17 Thread Xingbo Huang
Thanks Dong for driving this release. +1 (binding) - verify signatures and checksums - pip install apache-flink-ml source package and run simple example - download source code and build from source code - review release notes Best, Xingbo Guowei Ma 于2023年4月14日周五 15:54写道: > Hi Dong, > > Thanks

Re: [ANNOUNCE] Apache Flink 1.1.4.4 released

2022-03-15 Thread Xingbo Huang
Thanks a lot for being our release manager Konstantin and everyone who contributed. I have a question about pyflink. I see that there are no corresponding wheel packages uploaded on pypi, only the source package is uploaded. Is there something wrong with building the wheel packages? Best, Xingbo

Re: [ANNOUNCE] Apache Flink 1.1.4.4 released

2022-03-16 Thread Xingbo Huang
affected Flink > 1.13.6, the other release I was recently managing. I simply skipped a step > in the release guide. > > It should be fixed now. Could you double-check? > > Cheers, > > Konstantin > > On Wed, Mar 16, 2022 at 4:07 AM Xingbo Huang wrote: > > > Thank

Re: pyflink on Python 3.9 dev guide

2022-04-05 Thread Xingbo Huang
Hi Martjin and Luan, As of now, the main reason why PyFlink has not declared to support Python 3.9 is that the dependent apache-beam, and the versions of numpy and pyarrow that apache-beam depends on do not provide corresponding whl packages in Python 3.9. Users need source code installation, but

Re: Regarding java.lang.NullPointerException

2022-04-05 Thread Xingbo Huang
Hi Josemon, Can you provide the version of PyFlink you are using, and it would be better if you can also provide code snippets that can be easily reproduced this problem. Best, Xingbo Josemon Maliakal 于2022年4月5日周二 13:31写道: > Hello There, > I started using pyflink recently, > Have anyone know w

Re: pyflink on Python 3.9 dev guide

2022-04-06 Thread Xingbo Huang
ode: 1 > at > org.apache.flink.client.python.PythonDriver.main(PythonDriver.java:130) > ~[?:?] > ... 13 more > org.apache.flink.client.program.ProgramAbortException: > java.lang.RuntimeException: Python process exits with code: 1 > at > org.apache.flink.client.python.PythonDriver.main(Pytho

Re: Issue while running word_count.py

2022-04-21 Thread Xingbo Huang
Hi Rohith, I guess the `word_count.py` you tried to execute is from flink release-1.15 or master branch. For pyflink 1.14 you are using, you need to change `t_env.get_config().set_string("parallelism.default", "1")` to `t_env.get_config().get_configuration().set_string("parallelism.default", "1")`

Re: [VOTE] Release 1.15.0, release candidate #4

2022-04-22 Thread Xingbo Huang
+1 (non-binding) - Verified checksums and signatures - Verified Python wheel package contents - Pip install apache-flink-libraries source package and apache-flink wheel package in Mac/Linux - Run the examples from Python Table API Tutorial in Python REPL - Test the Python UDF jobs in Thread Mode.

Re: [DISCUSS] Planning Flink 1.16

2022-04-29 Thread Xingbo Huang
Thanks Konstantin and Chesnay for starting the discussion. I'm also willing to volunteer as the release manager if this is still open. Regarding the feature freeze date, +1 to the end of mid August. Best, Xingbo Zhu Zhu 于2022年4月29日周五 11:01写道: > +1 for a 5 months release cycle. > +1 target the

[DISCUSS] Releasing Flink 1.14.5

2022-05-23 Thread Xingbo Huang
Hi all, I would like to start discussing releasing Flink 1.14.5. It has already been more than two months since we released 1.14.4. There are currently 62 tickets[1] already resolved for 1.14.5, some of them quite severe. Currently, there are no issues marked as critical or blocker for 1.14.5. P

Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack

2022-06-07 Thread Xingbo Huang
Thanks everyone for the great effort driving this. +1 for building a dedicated channel for CI builds. Best, Xingbo Martijn Visser 于2022年6月8日周三 01:32写道: > Hi Matthias, > > I've only thought about it, but I absolutely would +1 this. Making this > information available in dedicated channels will

Re: [DISCUSS] Releasing Flink 1.14.5

2022-06-08 Thread Xingbo Huang
ere are already > > nearly > > > 100 commits [1] since 1.14.4. > > > > > > Regards, > > > Dian > > > > > > [1] > > https://github.com/apache/flink/compare/release-1.14.4...release-1.14 > > > > > > On Tue, May 24, 2022

Re: [DISCUSS] Releasing 1.15.1

2022-06-08 Thread Xingbo Huang
Hi David, +1 Thank you for driving this. Best, Xingbo Chesnay Schepler 于2022年6月8日周三 18:41写道: > +1 > > Thank you for proposing this. I can take care of the PMC-side of things. > > On 08/06/2022 12:37, Jingsong Li wrote: > > +1 > > > > Thanks David for volunteering to manage the release. > > > >

[VOTE] Release 1.14.5, release candidate #1

2022-06-10 Thread Xingbo Huang
Hi everyone, Please review and vote on the release candidate #1 for the version 1.14.5, 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: * JIRA release notes [1], *

Re: [ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee

2022-06-13 Thread Xingbo Huang
Congratulations, Jingsong! Best, Xingbo Jane Chan 于2022年6月13日周一 17:23写道: > Congratulations, Jingsong! > > Best, > Jane Chan > > On Mon, Jun 13, 2022 at 4:43 PM Shuo Cheng wrote: > > > Congratulations, Jingsong! > > > > On 6/13/22, Paul Lam wrote: > > > Congrats, Jingsong! Well deserved! > > >

Re: [VOTE] FLIP-228: Support Within between events in CEP Pattern

2022-06-13 Thread Xingbo Huang
+1 (binding) Best, Xingbo Dian Fu 于2022年6月13日周一 16:08写道: > +1 (binding) > > Regards, > Dian > > On Mon, Jun 13, 2022 at 3:55 PM Rui Fan <1996fan...@gmail.com> wrote: > > > Thanks for Nicholas driving this. > > > > +1(non-binding) > > > > Best, > > Rui Fan > > > > On Mon, Jun 13, 2022 at 3:05 PM

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

2022-06-13 Thread Xingbo Huang
this rc! > > Konstantin > > > Am Fr., 10. Juni 2022 um 11:58 Uhr schrieb Xingbo Huang < > hxbks...@gmail.com > >: > > > Hi everyone, > > > > Please review and vote on the release candidate #1 for the version > 1.14.5, > > as follows: >

[DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

2021-12-28 Thread Xingbo Huang
Hi everyone, I would like to start a discussion thread on "Support PyFlink Runtime Execution in Thread Mode" We have provided PyFlink Runtime framework to support Python user-defined functions since Flink 1.10. The PyFlink Runtime framework is called Process Mode, which depends on an inter-proces

Re: [DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

2021-12-31 Thread Xingbo Huang
nt c library if the python.executable is > provided by users? May there be a risk of version conflicts? > > Best, > Wei > > > > 2021年12月29日 上午11:56,Xingbo Huang 写道: > > > > Hi everyone, > > > > I would like to start a discussion thread on &quo

Re: [VOTE] Apache Flink ML Release 2.0.0, release candidate #3

2021-12-31 Thread Xingbo Huang
+1 (non-binding) - Verified checksums and signatures - Pip install the apache-flink-ml package - Run the apache-flink-ml tests (We will add more python examples in the next release https://issues.apache.org/jira/browse/FLINK-25497). Best, Xingbo Zhipeng Zhang 于2021年12月31日周五 15:01写道: > +1 (non-

Re: [DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

2022-01-05 Thread Xingbo Huang
> > > > > > What else are our Python users mainly complaining about? > > > > > > Concerning the proposed changes, are there any changes required on the > > > runtime side (changes to Flink)? How will the deployment and memory > > > manage

Re: [DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

2022-01-07 Thread Xingbo Huang
ely. > > If the mode solely needs changes in the Python part of Flink, then I don't > have any concerns from the runtime perspective. > > Cheers, > Till > > On Wed, Jan 5, 2022 at 1:55 PM Xingbo Huang wrote: > > > Hi Till and Thomas, > > > > Thanks a l

Re: [DISCUSS] Releasing Flink 1.14.3

2022-01-09 Thread Xingbo Huang
Hi Thomas, Since multiple wheel packages with different python versions for mac and linux are generated, building locally requires you have multiple machines with different os and Python environments. I have triggered the wheel package build of release-1.14.3-rc1 in my private Azure[1] and you can

Re: [DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

2022-01-11 Thread Xingbo Huang
Hi everyone, Thanks to all of you for the discussion. If there are no objections, I would like to start a vote thread tomorrow. Best, Xingbo Xingbo Huang 于2022年1月7日周五 16:18写道: > Hi Till, > > I have written a more complicated PyFlink job. Compared with the previous > single py

Re: [DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

2022-01-12 Thread Xingbo Huang
irements. > > Cheers, > Thomas > > On Tue, Jan 11, 2022 at 3:44 AM Xingbo Huang wrote: > > > > Hi everyone, > > > > Thanks to all of you for the discussion. > > If there are no objections, I would like to start a vote thread tomorrow. > > &

[VOTE] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

2022-01-12 Thread Xingbo Huang
Hi all, I would like to start the vote for FLIP-206[1], which was discussed and reached a consensus in the discussion thread[2]. The vote will be open for at least 72h, unless there is an objection or not enough votes. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-206%3A+Support+PyF

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

2022-01-13 Thread Xingbo Huang
+1 (non-binding) - Verified checksums and signatures - Verified Python wheel package contents - Pip install apache-flink-libraries source package and apache-flink wheel package in Mac - Run the examples from Python Table API Tutorial[1] in Python REPL [1] https://nightlies.apache.org/flink/flink-

[RESULT][VOTE] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

2022-01-17 Thread Xingbo Huang
Hi everyone, The voting time for FLIP-206: Support PyFlink Runtime Execution in Thread Mode[1] has passed. I'm closing the vote now. There were 4 +1 votes, 4 of which are binding: - Wei Zhong (binding) - Till Rohrmann (binding) - Thomas Weise (binding) - Dian Fu (binding) There were no -1 votes

  1   2   3   >