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] Watermark propagation with Sink API

+1 (binding) // Sorry for the late reply. Best, Jincheng Piotr Nowojski 于2021年6月9日周三 下午10:04写道： > Thanks for driving this Eron, and sorry for causing the delay. > > +1 (binding) from my side > > Piotrek > > wt., 8 cze 2021 o 23:48 Eron Wright > napisał(a): > > > Voting is re-open for FLIP-16

Re: [VOTE] FLIP-33: Standardize connector metrics

+1， Thanks for driving this, Becket! Best, Jincheng Becket Qin 于2020年9月21日周一 上午11:31写道： > Hi all, > > I would like to start the voting thread for FLIP-33 which proposes to > standardize the metrics of Flink connectors. > > In short, we would like to provide a convention and guidance of Flink >

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

Congratulations and welcome Arvid Heise. Best, Jincheng Piotr Nowojski 于2020年9月17日周四 下午3:33写道： > Congratulations :) > > czw., 17 wrz 2020 o 04:24 Zou Dan napisał(a): > > > Congratulations! > > > > Best, > > Dan Zou > > > > > 2020年9月16日 下午8:29，Yun Tang 写道： > > > > > > Congratulations , Arvid

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

Congratulations and welcome, Arvid ! Best, Jincheng Dian Fu 于2020年9月15日周二 上午10:53写道： > Congratulations! > > Regards, > Dian > > > 在 2020年9月15日，上午10:41，Matt Wang 写道： > > > > Congrats! > > > > > > -- > > > > Best, > > Matt Wang > > > > > > On 09/15/2020 10:38，Zhijiang wrote： > > Hi all, > > > >

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

+1 for the proposal! Regarding the name of `BATCH_OP/ROCKSDB`, we can reserve the configuration names for batch and rocksdb respectively, ` batch_ OP` for batch, "ROCKSDB" for roockdb. and the default value as follows: { BATCH_OP: 70, ROCKSDB : 70, PYTHON : 30 } Only one of `BATCH_ O

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

+1(binding) Best, Jincheng Xingbo Huang 于2020年9月7日周一 下午5:45写道： > 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]. > > >

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

+1(binding) Best, Jincheng Shuiqiang Chen 于2020年9月7日周一 下午3:50写道： > +1 (non-binding) > > > 在 2020年9月7日，下午2:38，Wei Zhong 写道： > > > > +1 (non-binding) > > > >> 在 2020年9月7日，10:00，Dian Fu 写道： > >> > >> +1 > >> > >>> 在 2020年9月4日，上午11:12，Xingbo Huang 写道： > >>> > >>> Hi all, > >>> I would like to s

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

art of the FLIP. > > Best, > Xingbo > > jincheng sun 于2020年9月3日周四 下午1:48写道： > > > Thanks for the update Xingbo! > > > > Pandas UDAF can reuse the `class aggregate function (user defined > > function)` interface in FLIP-139, and the core logic of Pandas UDAF users &

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

> unified. I will discuss it in FLIP-139 later. > > Best, > Xingbo > > jincheng sun 于2020年8月31日周一 上午11:05写道： > > > Hi Xingbo, > > > > Thanks for the discussion! Overall, + 1 for this FLIP. > > I have two points to add: > > > > - We also ne

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

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

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

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

[ANNOUNCE] New PMC member: Dian Fu

Hi all, On behalf of the Flink PMC, I'm happy to announce that Dian Fu is now part of the Apache Flink Project Management Committee (PMC). Dian Fu has been very active on PyFlink component, working on various important features, such as the Python UDF and Pandas integration, and keeps checking an

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

Hi everyone, The voting time for FLIP-133 is up. I'm going to finalize the vote. Up till now, there are 7 +1 votes, 4 of which are binding: - Seth Wiesman (binding) - Dian Fu (binding) - Hequn (binding) - Jincheng Sun(binding) - Wei Zhong(non-binding) - Xingbo Huang(non-binding) - Shui

Re: [ANNOUNCE] New Flink Committer: David Anderson

Congrats and welcome David! Best, Jincheng David Anderson 于2020年8月13日周四 上午2:51写道： > Thank you one and all for the warm reception! > > I'm honored to join the group of committers, and look forward to continuing > to work with the community to improve and evangelize Flink. > > Best regards, > Da

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

sman 写道： > > > > > > +1 (binding) > > > > > > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun > > > wrote: > > > > > >> Hi Seth, > > >> > > >> Thank you for joining the discussion and voting. Could you please &g

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

Thank you for your positive feedback Seth ! Would you please vote in the voting mail thread. Thank you! Best, Jincheng Seth Wiesman 于2020年8月10日周一 下午10:34写道： > I think this sounds good. +1 > > On Wed, Aug 5, 2020 at 8:37 PM jincheng sun > wrote: > >> Hi David, Than

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

> I'm sorry to be late to the discussion but I have some concerns I've > brought up in the discussion thread. > > Seth > > On Mon, Aug 3, 2020 at 3:00 AM jincheng sun > wrote: > > > Hi everyone, > > > > I would like to start the vote for FLIP-133[1],

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

n a specific way that I >> haven't thought of -- as in this case, where one can use a JDBC sink from >> Python if one thinks to use DDL. >> >> So I think it would be helpful to be explicit about both what is, and >> what is not, supported in PyFlink. And to have s

Re: [DISCUSS] Planning Flink 1.12

+1 for end of October from me as well. Best, Jincheng Kostas Kloudas 于2020年8月5日周三 下午4:59写道： > +1 for end of October from me as well. > > Cheers, > Kostas > > On Wed, Aug 5, 2020 at 9:59 AM Till Rohrmann wrote: > > > +1 for end of October from my side as well. > > > > Cheers, > > Till > > > >

Re: Status of FLIPs

Good job Dian! Thank you for helping to maintain the state of FLIPs which is very important for the community to understand the progress of FLIPs. Best, Jincheng Dian Fu 于2020年8月4日周二 下午5:41写道： > Hi all, > > When going through the status of existing FLIPs[1], I found that the > status of quite

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

documentation is currently > organized is that it's relatively straightforward to compare the Python API > with the Java and Scala versions. I'm concerned that if the PyFlink docs > are more independent, it will be challenging to respond to questions about > which features from the

[VOTE] FLIP-133: Rework PyFlink Documentation

Hi everyone, I would like to start the vote for FLIP-133[1], which is discussed and reached a consensus through the discussion thread[2]. The vote will be open until 6th August (72h), unless there is an objection or not enough votes. Best, Jincheng [1]: https://cwiki.apache.org/confluence/displ

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

Jincheng, >>> >> >>> >> Thanks a lot for bringing up this discussion and the proposal. +1 to >>> >> improve the Python API doc. >>> >> >>> >> I have received many feedbacks from PyFlink beginners about >>> >> th

[DISCUSS] FLIP-133: Rework PyFlink Documentation

Hi folks, Since the release of Flink 1.11, users of PyFlink have continued to grow. As far as I know there are many companies have used PyFlink for data analysis, operation and maintenance monitoring business has been put into production(Such as 聚美优品[1](Jumei), 浙江墨芷[2] (Mozhi) etc.). According t

Re: [VOTE] FLIP-130: Support for Python DataStream API (Stateless Part)

+1(binding) Best, Jincheng Shuiqiang Chen 于2020年7月24日周五 下午8:32写道： > Hi everyone, > > I would like to start the vote for FLIP-130[1], which is discussed and > reached a consensus through the discussion thread[2]. > > The vote will be open until 29th July (72h), unless there is an objection > or

Re: [VOTE] FLIP-129: Refactor Descriptor API to register connector in Table API

+1（binding) Best, Jincheng Jark Wu 于2020年7月27日周一 上午10:01写道： > +1 (binding) > > On Fri, 24 Jul 2020 at 22:22, Timo Walther wrote: > > > +1 > > > > Thanks for driving this Jark. > > > > Regards, > > Timo > > > > On 24.07.20 12:42, Jark Wu wrote: > > > Hi all, > > > > > > I would like to start t

Re: [DISCUSS] Planning Flink 1.12

Hi All, Thanks for bring-up this discussion, Robert! Congratulations on becoming the release manager of 1.12， Dian and Robert ! -- Here is my thoughts of the features for PyFlink in Flink 1.12: 1. Improve the usabilities for PyFlink Description: Improve the usabilities for PyFlin

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

+1(binding) Checks: - checked the signature and checksum - test the built from the wheel package - check wheel package consistency - pip installed the Python package and run a word count example successfully Best, Jincheng Zhu Zhu 于2020年7月21日周二 上午11:25写道： > +1 (non-binding) > > -

Re: [DISCUSS] FLIP-130: Support for Python DataStream API (Stateless Part)

Thanks for bring up this DISCUSS Shuiqiang! +1 for the proposal! Best, Jincheng Xingbo Huang 于2020年7月9日周四 上午10:41写道： > Hi Shuiqiang, > > Thanks a lot for driving this discussion. > Big +1 for supporting Python DataStream. > In many ML scenarios, operating Object will be more natural than oper

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

Thanks for bring up this discussion Jark. +1, looking forward the first bugfix version of Flink 1.11. Best, Jincheng Dian Fu 于2020年7月9日周四 下午5:28写道： > Thanks Jark for bringing up this discussion. I also noticed that there are > already users trying out the CDC feature and so it makes sense to ha

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

+1(binding) Checks: - check wheel package consistency - test the built from the wheel package - checked the signature and checksum - pip installed the Python package `apache_flink-1.11.0-cp37-cp37m-macosx_10_9_x86_64.whl` successfully and run a simple word count example successfully

[ANNOUNCE] Yu Li is now part of the Flink PMC

Hi all, On behalf of the Flink PMC, I'm happy to announce that Yu Li is now part of the Apache Flink Project Management Committee (PMC). Yu Li has been very active on Flink's Statebackend component, working on various improvements, for example the RocksDB memory management for 1.10. and keeps che

Re: Please update the Requirements of PyPI

Thanks Ray and Till, Could you provide more information about the errors you encountered? Is it the same error message as reported in https://issues.apache.org/jira/browse/BEAM-8368? Best, Jincheng Till Rohrmann 于2020年5月25日周一 下午4:28写道： > Thanks for the pointer Ray. I've pulled in Jincheng who

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

+1(binding) - built from source and run Streaming word count without unexpected information. - check the signatures, looks good! BTW: I've added your PyPI account(carp84) as a maintainer role. Great job Yu! Best, Jincheng Hequn Cheng 于2020年5月12日周二 上午9:49写道： > +1 (binding) > > - Go through all

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: [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] 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: [DISCUSS] Releasing Flink 1.10.1

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

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

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

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

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

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 PyCha

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

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

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

n I'm willing to take these JIRAs. Could you assign them to me? > :) > > Best, > Wei > > > > 在 2020年2月5日，14:49，jincheng sun 写道： > > > > Hi everyone, > > > > Please review and vote on the release candidate #0 for the PyFlink > version > > 1.9

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

> > > 在 2020年2月5日，上午8:56，jincheng sun 写道： > > > > I see, thanks for the confirmation Aljoscha! > > > > Best, > > Jincheng > > > > > > > > Aljoscha Krettek 于2020年2月4日周二 下午9:58写道： > > > >> Yes, as I said I think it's sti

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

Hi everyone, Please review and vote on the release candidate #0 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 Apac

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

Thanks everyone for your positive feedback, I will continue to push forward the subsequent release process. Best, Jincheng jincheng sun 于2020年2月5日周三 上午8:56写道： > I see, thanks for the confirmation Aljoscha! > > Best, > Jincheng > > > > Aljoscha Krettek 于2020年2月4日周二

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

I see, thanks for the confirmation Aljoscha! Best, Jincheng Aljoscha Krettek 于2020年2月4日周二 下午9:58写道： > Yes, as I said I think it's still good to release. > > On 04.02.20 13:49, jincheng sun wrote: > > Hi Aljoscha, > > > > I agree that the coming PyFlink package

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

Thanks for bring up this discussion Xingbo! The the design is pretty nice for me! This feature is really need which 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

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

t; Hi Jincheng, > >>>> > >>>> Thanks for bring up this discussion! > >>>> > >>>> +1 for this proposal. Building from source takes long time and > requires > >>>> a good network environment. Some users may not have such an >

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

Hi folks, I am very happy to receive some user inquiries about the use of Flink Python API (PyFlink) recently. One of the more common questions is whether it is possible to install PyFlink without using source code build. The most convenient and natural way for users is to use `pip install apache-

Re: [DISCUSS] Include flink-ml-api and flink-ml-lib in opt

t; > Thanks a lot for your feedback! > > Yes, I agree with you. There are cases that multi jars need to be > > uploaded. I will prepare another discussion later. Maybe with a simple > > design doc. > > > > Best, Hequn > > > > On Wed, Jan 8, 2020 at 3:06 PM j

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

Hi folks, I found another issue related to Blink planner that ClassCastException would be thrown when use ConnectorDescriptor to register the Source. Not sure if it is a blocker. The issue can be found in [1], anyway, it's better to fix this issue in new RC. Best, Jincheng [1] https://issues.apa

Re: [ANNOUNCE] Apache Flink 1.9.2 released

Thanks for being the release manager and the great work Hequn :) Also thanks to the community making this release possible! BTW: I have add the 1.9.2 release to report. Best, Jincheng Hequn Cheng 于2020年1月31日周五 下午6:55写道： > Hi everyone, > > The Apache Flink community is very happy to announce t

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 unexpe

Re: [ANNOUNCE] Yu Li became a Flink committer

Good to have you on board Yu！ Peter Huang 于2020年1月24日 周五00:26写道： > Congratulations! > > On Thu, Jan 23, 2020 at 7:49 AM Kostas Kloudas wrote: > > > Congratulations Yu and welcome! > > > > On Thu, Jan 23, 2020 at 2:28 PM Till Rohrmann > > wrote: > > > > > > Congrats Yu :-) > > > > > > On Thu, Ja

Re: [DISCUSS] Releasing Flink 1.9.2

; >>> to properly test the 1.9 RC. Additionally, many people will be on > >>> Christmas > >>> vacations during the next 2 weeks. If this is it not a problem and we > >>> have > >>> enough resources for a parallel release then we

Re: [ANNOUNCE] Dian Fu becomes a Flink committer

Congrats Dian Fu and welcome on board! Best, Jincheng Shuo Cheng 于2020年1月16日周四 下午6:22写道： > Congratulations! Dian Fu > > > Xingbo Wei Zhong 于2020年1月16日周四 下午6:13写道： >> jincheng sun > 于2020年1月16日周四 下午5:58写道： >

[ANNOUNCE] Dian Fu becomes a Flink committer

Hi everyone, I'm very happy to announce that Dian accepted the offer of the Flink PMC to become a committer of the Flink project. Dian Fu has been contributing to Flink for many years. Dian Fu played an essential role in PyFlink/CEP/SQL/Table API modules. Dian Fu has contributed several major fea

Re: [DISCUSS] Include flink-ml-api and flink-ml-lib in opt

Thanks for bring up this discussion Hequn! +1 for include `flink-ml-api` and `flink-ml-lib` in opt. BTW: I think would be great if bring up a discussion for upload multiple Jars at the same time. as PyFlink JOB also can have the benefit if we do that improvement. Best, Jincheng Hequn Cheng 于2

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

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

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 the

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

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

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 De

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 于2019年12月5日周四

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 dis

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 i

  1   2   3   4   >