Re: Two potential bugs in Flink ML

2024-04-11 Thread Komal M
Hi Yunfeng, Thank you for the prompt action on resolving this bug. I have compiled the latest Flink ML source code and can confirm the problem has indeed been solved. Regarding the second bug relating to the IterationListener interface, it seems that the methods in the IterationListener

Re: Two potential bugs in Flink ML

2024-04-09 Thread Yunfeng Zhou
Hi Komal, Thanks for your example code! I found that Flink ML has a bug when it comes to keyed two input operators. I have submitted a PR to fix this bug and you can build the Flink ML library for your program according to its document after this PR is approved. The bugfix PR: https://github.com

Re: Two potential bugs in Flink ML

2024-04-07 Thread Komal M
DataStreamList.of(newModelUpdate), DataStreamList.of(finalOutput)); }); result.get(0).print(); // Execute program env.execute("Flink Java API Skeleton"); } } Best, Komal From: Yunfeng Zhou Date

Re: Two potential bugs in Flink ML

2024-04-06 Thread Yunfeng Zhou
Hi Komal, For the first question, could you please provide a simple program that could help reproduce this exception? That could help us better find out the bugs (if any) in Flink ML. For the second question, there have been Functions implementing the IterationListener interface in Flink ML[1

Two potential bugs in Flink ML

2024-04-04 Thread Komal M
Hi Flink Dev Team, I have two possible bugs to report for Flink ML Iteration. Flink v1.17.2 Flink ML v2.3.0 Java 11 Bug # 1 Implementing a UDF KeyedRichCoProcessFunction or CoFlatMapFunction inside IterationBody yields a “java.lang.ClassCastException: org.apache.flink.iteration.IterationRecord

[jira] [Created] (FLINK-33003) Flink ML add isolationForest algorithm

2023-08-30 Thread zhaozijun (Jira)
zhaozijun created FLINK-33003: - Summary: Flink ML add isolationForest algorithm Key: FLINK-33003 URL: https://issues.apache.org/jira/browse/FLINK-33003 Project: Flink Issue Type: New Feature

Keying a data stream by tenant and performing Flink ML tasks on each sub-stream ?

2023-07-18 Thread Catalin Stavaru
Hello everyone, Please forgive me if this is not the correct mailing list for the issue below. Here is my use case: I have an event data stream which I need to "keyby" a certain field (tenant id) and then for each tenant's events I need to independently perform ML clustering using FlinkML's Onlin

[jira] [Created] (FLINK-32588) Flink ML unittest BoundedPerRoundStreamIterationITCase failed

2023-07-13 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-32588: - Summary: Flink ML unittest BoundedPerRoundStreamIterationITCase failed Key: FLINK-32588 URL: https://issues.apache.org/jira/browse/FLINK-32588 Project: Flink

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

2023-06-29 Thread Dong Lin
Sorry, I used the wrong title. I just sent another email with the right title to announce the voting result. On Fri, Jun 30, 2023 at 7:26 AM Dong Lin wrote: > Hi all, > > I'm happy to announce that we have unanimously approved this release [1]. > > There are 5 approving votes, 3 of which are bin

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

2023-06-29 Thread Dong Lin
Hi all, I'm happy to announce that we have unanimously approved this release [1]. There are 5 approving votes, 3 of which are binding: - Dian Fu (binding) - Xingbo Huang (binding) - Dong Lin (binding) - Xin Jiang (non-binding) - Zhipeng Zhang (non-binding) There are no disapproving votes. Than

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

2023-06-29 Thread Dong Lin
Hi all, I'm happy to announce that we have unanimously approved this release [1]. There are 5 approving votes, 3 of which are binding: - Dian Fu (binding) - Xingbo Huang (binding) - Dong Lin (binding) - Xin Jiang (non-binding) - Zhipeng Zhang (non-binding) There are no disapproving votes. Than

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

2023-06-29 Thread Dong Lin
I will also vote +1 (binding). - Verified checksums and GPG for all maven artifacts and source distributions - Successfully run the Flink ML Python/Java quickstart using source distributions. - Verified that the source distributions do not contain any unwanted binaries. - Built the source

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

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

2023-06-29 Thread Dian Fu
+1 (binding) - Verified the checksums and signatures. - The website PR LGTM Regards, Dian On Thu, Jun 29, 2023 at 7:03 PM Zhipeng Zhang wrote: > > Thanks Dong and Xin for driving this release. > > +1 (non-binding) > > - Verified that the checksums and GPG files. > - Verified that the source dis

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

2023-06-29 Thread Zhipeng Zhang
Thanks Dong and Xin for driving this release. +1 (non-binding) - Verified that the checksums and GPG files. - Verified that the source distributions do not contain any binaries. - Browsed through JIRA release notes files. - Browsed through README.md files. Xin Jiang 于2023年6月29日周四 12:08写道: > > H

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

2023-06-28 Thread Xin Jiang
Hi Dong, Thanks for driving this release. +1 (non-binding) - Verified that the checksums and GPG files. - Verified that the source distributions do not contain any binaries. - Built the source distribution and run all unit tests. - Verified that all POM files point to the same version. - Browsed

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

2023-06-26 Thread Dong Lin
Hi everyone, We would like to start voting for the Flink ML 2.3.0 release. This release primarily provides the ability to run Flink ML on Flink 1.15, 1.16 and 1.17. Please review and vote on the release candidate #1 for version 2.3.0 of Apache Flink ML as follows. [ ] +1, Approve the release

Re: [DISCUSS] Releasing Flink ML 2.3.0

2023-06-25 Thread Xin Jiang
Since there's no reply that is -1, we will kick off the release process. Best Regards, Xin

[jira] [Created] (FLINK-32424) Flink ML CI fails due to NPE

2023-06-25 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-32424: - Summary: Flink ML CI fails due to NPE Key: FLINK-32424 URL: https://issues.apache.org/jira/browse/FLINK-32424 Project: Flink Issue Type: Bug Components

[DISCUSS] Releasing Flink ML 2.3.0

2023-06-21 Thread Xin Jiang
Hi devs, Dong and I would like to start a discussion regarding the release of Flink ML 2.3.0. The release mainly provides the ability to run on multiple Flink versions. With 2.3.0, users can build and run Flink ML libraries with Flink 1.15, 1.16, and 1.17. Besides, some algorithm performence

[jira] [Created] (FLINK-32335) Fix the Flink ML unittest failure

2023-06-14 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-32335: - Summary: Fix the Flink ML unittest failure Key: FLINK-32335 URL: https://issues.apache.org/jira/browse/FLINK-32335 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-32285) Support multiple Flink versions in each Flink ML Java library release

2023-06-07 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-32285: - Summary: Support multiple Flink versions in each Flink ML Java library release Key: FLINK-32285 URL: https://issues.apache.org/jira/browse/FLINK-32285 Project: Flink

[jira] [Created] (FLINK-31899) Upgrade Flink version of Flink ML to 1.17.0

2023-04-23 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-31899: - Summary: Upgrade Flink version of Flink ML to 1.17.0 Key: FLINK-31899 URL: https://issues.apache.org/jira/browse/FLINK-31899 Project: Flink Issue Type

[jira] [Created] (FLINK-31887) Upgrade Flink version of Flink ML to 1.17.0

2023-04-23 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-31887: - Summary: Upgrade Flink version of Flink ML to 1.17.0 Key: FLINK-31887 URL: https://issues.apache.org/jira/browse/FLINK-31887 Project: Flink Issue Type

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

2023-04-18 Thread Dong Lin
I'm happy to announce that we have unanimously approved this release [1]. There are 4 approving votes, 3 of which are binding: - Guowei Ma (binding) - Xingbo Huang (binding) - Dong Lin (binding) - Zhipeng Zhang (non-binding) There are no disapproving votes. Thank you for verifying the release c

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 D

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

2023-04-14 Thread Guowei Ma
gt; Please review and vote on the release candidate #2 for version 2.2.0 of > > Apache Flink ML as follows: > > > > [ ] +1, Approve the release > > [ ] -1, Do not approve the release (please provide specific comments) > > > > **Testing Guideline** > > > > Yo

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

2023-04-13 Thread Zhipeng Zhang
to the same version. - Browsed through JIRA release notes files. - Browsed through README.md files. - Verified the source code tag. Dong Lin 于2023年4月13日周四 18:28写道: > > Hi everyone, > > Please review and vote on the release candidate #2 for version 2.2.0 of > Apache Flink ML as foll

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

2023-04-13 Thread Dong Lin
Hi everyone, Please review and vote on the release candidate #2 for version 2.2.0 of Apache Flink ML as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Testing Guideline** You can find here [1] a page in the project wiki on

[jira] [Created] (FLINK-31732) flink-ml-uber module should include statefun as a dependency

2023-04-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31732: - Summary: flink-ml-uber module should include statefun as a dependency Key: FLINK-31732 URL: https://issues.apache.org/jira/browse/FLINK-31732 Project: Flink

Re: [DISCUSS] Releasing Flink ML 2.2.0

2023-04-03 Thread Dong Lin
Thanks everyone for the comments! We will go ahead to release Flink ML 2.2.0. Please see here <https://cwiki.apache.org/confluence/display/FLINK/2.2.0+Release> for the release plan. Best Regards, Dong On Fri, Mar 31, 2023 at 6:50 PM Yu Li wrote: > +1. Great to know the (exciting)

Re: [DISCUSS] Releasing Flink ML 2.2.0

2023-03-31 Thread Yu Li
+1. Great to know the (exciting) progress and thanks for the efforts! Best Regards, Yu On Fri, 31 Mar 2023 at 14:39, Fan Hong wrote: > Hi Dong and Zhipeng, > > Thanks for starting the discussion. Glad to see a new release of Flink ML. > > Cheers! > > On Fri, Mar 31, 20

Re: [DISCUSS] Releasing Flink ML 2.2.0

2023-03-30 Thread Fan Hong
Hi Dong and Zhipeng, Thanks for starting the discussion. Glad to see a new release of Flink ML. Cheers! On Fri, Mar 31, 2023 at 2:34 PM Zhipeng Zhang wrote: > Hi Dong, > > Thanks for starting the discussion. +1 for the Flink ML 2.1.0 release. >

Re: [DISCUSS] Releasing Flink ML 2.2.0

2023-03-30 Thread Zhipeng Zhang
Hi Dong, Thanks for starting the discussion. +1 for the Flink ML 2.1.0 release.

[DISCUSS] Releasing Flink ML 2.2.0

2023-03-29 Thread Dong Lin
Hi devs, Zhipeng and I would like to start a discussion regarding the release of Flink ML 2.2.0. And I would like to volunteer as the release manager. Over the past few months, we've been focused on enhancing Flink ML's feature engineering capabilities. We're happy to report that

Re: [VOTE] FLIP-289: Support online inference (Flink ML)

2023-02-26 Thread Dian Fu
> >> +1 (binding) > > >> > > >> Regards, > > >> Zhipeng > > >> > > >> Dian Fu 于2023年2月13日周一 20:21写道: > > >> > > > >> > +1 (binding) > > >> > > > >> &g

Re: [VOTE] FLIP-289: Support online inference (Flink ML)

2023-02-23 Thread Zhipeng Zhang
t; >> > +1 (binding) > >> > > >> > Regards, > >> > Dian > >> > > >> > On Mon, Feb 13, 2023 at 11:04 AM Dong Lin wrote: > >> > > >> > > Hi all, > >> > > > >> > > We would

Re: [VOTE] FLIP-289: Support online inference (Flink ML)

2023-02-23 Thread Dong Lin
gt; > Regards, >> > Dian >> > >> > On Mon, Feb 13, 2023 at 11:04 AM Dong Lin wrote: >> > >> > > Hi all, >> > > >> > > We would like to start the vote for FLIP-289: Support online inference >> > > (Flink ML) [1]. T

[jira] [Created] (FLINK-31126) Move classes not dependenting on Flink runtime from flink-ml-core to flink-ml-servable-core

2023-02-19 Thread Dong Lin (Jira)
Dong Lin created FLINK-31126: Summary: Move classes not dependenting on Flink runtime from flink-ml-core to flink-ml-servable-core Key: FLINK-31126 URL: https://issues.apache.org/jira/browse/FLINK-31126

[jira] [Created] (FLINK-31125) Flink ML benchmark result should not include data generation overhead

2023-02-17 Thread Dong Lin (Jira)
Dong Lin created FLINK-31125: Summary: Flink ML benchmark result should not include data generation overhead Key: FLINK-31125 URL: https://issues.apache.org/jira/browse/FLINK-31125 Project: Flink

[RESULT][VOTE] FLIP-289: Support online inference (Flink ML)

2023-02-16 Thread Dong Lin
Hi all, I am happy to announce that FLIP-289: Support online inference (Flink ML) [1] has been accepted. There are 3 binding votes [2]: - Dian Fu (binding) - Zhipeng Zhang (binding) - Dong Lin (binding) There is no disapproving vote. Regards, Dong [1] https://cwiki.apache.org/confluence/pages

Re: [VOTE] FLIP-289: Support online inference (Flink ML)

2023-02-16 Thread Dong Lin
ing) > > > > Regards, > > Dian > > > > On Mon, Feb 13, 2023 at 11:04 AM Dong Lin wrote: > > > > > Hi all, > > > > > > We would like to start the vote for FLIP-289: Support online inference > > > (Flink ML) [1]. This FLIP was discu

Re: [VOTE] FLIP-289: Support online inference (Flink ML)

2023-02-16 Thread Zhipeng Zhang
+1 (binding) Regards, Zhipeng Dian Fu 于2023年2月13日周一 20:21写道: > > +1 (binding) > > Regards, > Dian > > On Mon, Feb 13, 2023 at 11:04 AM Dong Lin wrote: > > > Hi all, > > > > We would like to start the vote for FLIP-289: Support online inference >

Re: [VOTE] FLIP-289: Support online inference (Flink ML)

2023-02-13 Thread Dian Fu
+1 (binding) Regards, Dian On Mon, Feb 13, 2023 at 11:04 AM Dong Lin wrote: > Hi all, > > We would like to start the vote for FLIP-289: Support online inference > (Flink ML) [1]. This FLIP was discussed in this thread [2]. > > The goal of this FLIP is to enable users to use

[VOTE] FLIP-289: Support online inference (Flink ML)

2023-02-12 Thread Dong Lin
Hi all, We would like to start the vote for FLIP-289: Support online inference (Flink ML) [1]. This FLIP was discussed in this thread [2]. The goal of this FLIP is to enable users to use the model trained by Flink ML to do online inference. The vote will be open until at least Feb 16th (at

Re: [DISCUSS] FLIP-289: Support online inference (Flink ML)

2023-02-09 Thread Dian Fu
lready > computed before this method is called. > > > > 2) For the method `DataFrame.addColumn`, when will this method be used? > > > > For example, we might want to implement KMeansModelServable#transform > that appends the prediction result to the input dataFrame. This

Re: [DISCUSS] FLIP-289: Support online inference (Flink ML)

2023-02-08 Thread Dong Lin
his method is called. > 2) For the method `DataFrame.addColumn`, when will this method be used? > For example, we might want to implement KMeansModelServable#transform that appends the prediction result to the input dataFrame. This is similar to the existing way that KMeansModel#transfor

Re: [DISCUSS] FLIP-289: Support online inference (Flink ML)

2023-02-07 Thread Dian Fu
gt; > > > Fan, Jiang, Zhipeng, and I have created FLIP-289: Support online > inference > > (Flink ML). > > > > The goal of this FLIP is to enable users to use the model trained by > Flink > > ML to do online inference. More details can be found in the

Re: [DISCUSS] FLIP-289: Support online inference (Flink ML)

2023-02-06 Thread Dong Lin
Hi all, If there is no question related to this FLIP, we will start the voting thread on 2/10. Regards, Dong On Wed, Feb 1, 2023 at 8:38 PM Dong Lin wrote: > Hi all, > > Fan, Jiang, Zhipeng, and I have created FLIP-289: Support online inference > (Flink ML). > > The goal

[DISCUSS] FLIP-289: Support online inference (Flink ML)

2023-02-01 Thread Dong Lin
Hi all, Fan, Jiang, Zhipeng, and I have created FLIP-289: Support online inference (Flink ML). The goal of this FLIP is to enable users to use the model trained by Flink ML to do online inference. More details can be found in the FLIP doc at https://cwiki.apache.org/confluence/pages

[jira] [Created] (FLINK-30865) Make pyflink-ml modules consistent with Flink ML Java library packages

2023-02-01 Thread Dong Lin (Jira)
Dong Lin created FLINK-30865: Summary: Make pyflink-ml modules consistent with Flink ML Java library packages Key: FLINK-30865 URL: https://issues.apache.org/jira/browse/FLINK-30865 Project: Flink

[jira] [Created] (FLINK-30688) Disable Kryo fallback in Flink ML tests

2023-01-14 Thread Dong Lin (Jira)
Dong Lin created FLINK-30688: Summary: Disable Kryo fallback in Flink ML tests Key: FLINK-30688 URL: https://issues.apache.org/jira/browse/FLINK-30688 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30241) Flink ML Iteration ConcurrentModificationException

2022-11-29 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-30241: Summary: Flink ML Iteration ConcurrentModificationException Key: FLINK-30241 URL: https://issues.apache.org/jira/browse/FLINK-30241 Project: Flink Issue

[jira] [Created] (FLINK-30144) Guarantee Flink ML operators function correctly with object-reuse enabled

2022-11-22 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-30144: Summary: Guarantee Flink ML operators function correctly with object-reuse enabled Key: FLINK-30144 URL: https://issues.apache.org/jira/browse/FLINK-30144 Project

[jira] [Created] (FLINK-30142) Flink ML operators lose table watermark after transform()

2022-11-22 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-30142: Summary: Flink ML operators lose table watermark after transform() Key: FLINK-30142 URL: https://issues.apache.org/jira/browse/FLINK-30142 Project: Flink

[jira] [Created] (FLINK-30122) Flink ML KMeans getting model data throws TypeError

2022-11-21 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-30122: Summary: Flink ML KMeans getting model data throws TypeError Key: FLINK-30122 URL: https://issues.apache.org/jira/browse/FLINK-30122 Project: Flink Issue

[jira] [Created] (FLINK-30037) Improve the efficiency of Flink ML Python CI

2022-11-15 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-30037: Summary: Improve the efficiency of Flink ML Python CI Key: FLINK-30037 URL: https://issues.apache.org/jira/browse/FLINK-30037 Project: Flink Issue Type

[jira] [Created] (FLINK-29429) Add DataType for Flink ML linear algorithm classes

2022-09-27 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-29429: Summary: Add DataType for Flink ML linear algorithm classes Key: FLINK-29429 URL: https://issues.apache.org/jira/browse/FLINK-29429 Project: Flink Issue

[jira] [Created] (FLINK-29426) Flink ML 2.1.0 Installation

2022-09-26 Thread Tony Sun (Jira)
Tony Sun created FLINK-29426: Summary: Flink ML 2.1.0 Installation Key: FLINK-29426 URL: https://issues.apache.org/jira/browse/FLINK-29426 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-29424) Add Pull Request Template for flink-ml Project

2022-09-26 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-29424: - Summary: Add Pull Request Template for flink-ml Project Key: FLINK-29424 URL: https://issues.apache.org/jira/browse/FLINK-29424 Project: Flink Issue Type: New

[jira] [Created] (FLINK-29141) Remove Scala Suffix from flink-ml download instructions

2022-08-30 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29141: Summary: Remove Scala Suffix from flink-ml download instructions Key: FLINK-29141 URL: https://issues.apache.org/jira/browse/FLINK-29141 Project: Flink

[jira] [Created] (FLINK-29115) Improve the quickstart of Flink ML python API

2022-08-26 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-29115: Summary: Improve the quickstart of Flink ML python API Key: FLINK-29115 URL: https://issues.apache.org/jira/browse/FLINK-29115 Project: Flink Issue Type

[jira] [Created] (FLINK-28673) Migrate Flink ML to Flink 1.15.1

2022-07-25 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-28673: Summary: Migrate Flink ML to Flink 1.15.1 Key: FLINK-28673 URL: https://issues.apache.org/jira/browse/FLINK-28673 Project: Flink Issue Type: Improvement

[ANNOUNCE] Apache Flink ML 2.1.0 released

2022-07-12 Thread Zhipeng Zhang
The Apache Flink community is excited to announce the release of Flink ML 2.1.0! This release focuses on improving Flink ML's infrastructure, such as Python SDK, memory management, and benchmark framework, to facilitate the development of performant, memory-safe, and easy-to-use algo

[RESULT] [VOTE] Apache Flink ML Release 2.1.0, release candidate #2

2022-07-07 Thread Zhipeng Zhang
I'm happy to announce that we have unanimously approved this release [1]. * Dong Lin (non-binding) * Yunfeng Zhou (non-binding) * Dian Fu (binding) * Yun Gao (binding) * Becket Qin (binding) There are no disapproving votes. Thanks everyone! [1] https://lists.apache.org/list.html?dev@flink.apach

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

2022-07-06 Thread Becket Qin
n any binary files. - verified the pom files and the flink-ml versions are updated. Thanks, Jiangjie (Becket) Qin On Tue, Jul 5, 2022 at 3:58 PM Yun Gao wrote: > +1 (binding) > > - Verified the checksum and signatures. > - Build from sources without exceptions. > - Checked the artifa

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

2022-07-05 Thread Yun Gao
Send Time:2022 Jul. 5 (Tue.) 14:45 To:dev Subject:Re: [VOTE] Apache Flink ML Release 2.1.0, release candidate #2 +1 (binding) - Verified the checksum and signature - Installed the Python package and runs an example documented here[1] - Reviewed the website PR and LGTM overall Regards, Dian [1

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

2022-07-04 Thread Dian Fu
+1 (binding) - Verified the checksum and signature - Installed the Python package and runs an example documented here[1] - Reviewed the website PR and LGTM overall Regards, Dian [1] https://nightlies.apache.org/flink/flink-ml-docs-master/docs/operators/clustering/kmeans/#examples On Mon, Jul 4

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

2022-07-03 Thread Yunfeng Zhou
e, > > > > > > Please review and vote on the release candidate #2 for the version 2.1.0 > of > > Apache Flink ML as follows: > > > > [ ] +1, Approve the release > > > > [ ] -1, Do not approve the release (please provide specific comments) > > >

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

2022-06-30 Thread Dong Lin
2.0.0-rc2" and did not find anything unexpected. On Fri, Jul 1, 2022 at 11:11 AM Zhipeng Zhang wrote: > Hi everyone, > > > Please review and vote on the release candidate #2 for the version 2.1.0 of > Apache Flink ML as follows: > > [ ] +1, Approve the release > &g

[VOTE] Apache Flink ML Release 2.1.0, release candidate #2

2022-06-30 Thread Zhipeng Zhang
Hi everyone, Please review and vote on the release candidate #2 for the version 2.1.0 of Apache Flink ML as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Testing Guideline** You can find here [1] a page in the project wiki on

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

2022-06-29 Thread Zhipeng Zhang
Hi Dong, Thanks for the check. I will cancel this release and release RC2 today. Dong Lin 于2022年6月30日周四 08:47写道: > Hi Zhipeng, > > I just realized that these two PRs (link > <https://github.com/apache/flink-ml/pull/115> and link > <https://github.com/apache/flink-ml/pul

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

2022-06-29 Thread Dong Lin
Hi Zhipeng, I just realized that these two PRs (link <https://github.com/apache/flink-ml/pull/115> and link <https://github.com/apache/flink-ml/pull/121>) are not included in the release branch, which means that the Flink ML 2.1 website will not include the documentation

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

2022-06-29 Thread Dong Lin
"release-2.0.0-rc1" and did not find anything unexpected. On Tue, Jun 28, 2022 at 5:28 PM Zhipeng Zhang wrote: > Hi everyone, > > Please review and vote on the release candidate #1 for the version 2.1.0 of > Apache Flink ML as follows: > [ ] +1, Approve the release > [ ] -1

[VOTE] Apache Flink ML Release 2.1.0, release candidate #1

2022-06-28 Thread Zhipeng Zhang
Hi everyone, Please review and vote on the release candidate #1 for the version 2.1.0 of Apache Flink ML as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Testing Guideline** You can find here [1] a page in the project wiki on

Re: [DISCUSS] Releasing Flink ML 2.1.0

2022-06-26 Thread Zhipeng Zhang
Thank you all for the vote and the comments! Based on the response received in this thread, we will go ahead and release Flink ML 2.1.0 RC1 today. Cheers, Zhipeng Jing Ge 于2022年6月25日周六 06:30写道: > +1 > > Looking forward to the new release! Thanks! > > Best regards, > Jing &g

Re: [DISCUSS] Releasing Flink ML 2.1.0

2022-06-24 Thread Jing Ge
+1 Looking forward to the new release! Thanks! Best regards, Jing On Fri, Jun 24, 2022 at 4:56 AM Becket Qin wrote: > +1. > > It looks like we have some decent progress on Flink ML :) > > Thanks, > > Jiangjie (Becket) Qin > > On Fri, Jun 24, 2022 at 8:29 AM Dong L

[jira] [Created] (FLINK-28237) Improve the flink-ml python examples in doc

2022-06-23 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28237: Summary: Improve the flink-ml python examples in doc Key: FLINK-28237 URL: https://issues.apache.org/jira/browse/FLINK-28237 Project: Flink Issue Type

Re: [DISCUSS] Releasing Flink ML 2.1.0

2022-06-23 Thread Becket Qin
+1. It looks like we have some decent progress on Flink ML :) Thanks, Jiangjie (Becket) Qin On Fri, Jun 24, 2022 at 8:29 AM Dong Lin wrote: > Hi Zhipeng and Yun, > > Thanks for starting the discussion. +1 for the Flink ML 2.1.0 release. > > Cheers, > Dong > > On Thu,

Re: [DISCUSS] Releasing Flink ML 2.1.0

2022-06-23 Thread Dong Lin
Hi Zhipeng and Yun, Thanks for starting the discussion. +1 for the Flink ML 2.1.0 release. Cheers, Dong On Thu, Jun 23, 2022 at 11:15 AM Zhipeng Zhang wrote: > Hi devs, > > Yun and I would like to start a discussion for releasing Flink ML > <https://github.com/apache/flink-ml

Re: [DISCUSS] Releasing Flink ML 2.1.0

2022-06-23 Thread Xingbo Huang
Hi Yun and Zhipeng, Thanks a lot for starting the discussion. +1 for the FLINK ML 2.1.0 release. Looking forward for these ML algorithms. I plan to write a blog about PyFlink + Flink ML after the released. Best, Xingbo Zhipeng Zhang 于2022年6月23日周四 11:15写道: > Hi devs, > > Yun and I w

[jira] [Created] (FLINK-28224) Add document for algorithms and features in Flink ML 2.1

2022-06-23 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-28224: Summary: Add document for algorithms and features in Flink ML 2.1 Key: FLINK-28224 URL: https://issues.apache.org/jira/browse/FLINK-28224 Project: Flink

[DISCUSS] Releasing Flink ML 2.1.0

2022-06-22 Thread Zhipeng Zhang
Hi devs, Yun and I would like to start a discussion for releasing Flink ML <https://github.com/apache/flink-ml> 2.1.0. In the past few months, we focused on improving the infra (e.g. memory management, benchmark infra, online training, python support) of Flink ML by implementing, benchm

[jira] [Created] (FLINK-27798) Migrate Flink ML to Flink 1.15.0

2022-05-26 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-27798: Summary: Migrate Flink ML to Flink 1.15.0 Key: FLINK-27798 URL: https://issues.apache.org/jira/browse/FLINK-27798 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27742) Fix Compatibility Issues Between Flink ML Operators.

2022-05-23 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-27742: Summary: Fix Compatibility Issues Between Flink ML Operators. Key: FLINK-27742 URL: https://issues.apache.org/jira/browse/FLINK-27742 Project: Flink Issue

[jira] [Created] (FLINK-27096) Benchmark all algorithms included in Flink ML 2.1 release and achieve performance parity with Spark

2022-04-06 Thread Dong Lin (Jira)
Dong Lin created FLINK-27096: Summary: Benchmark all algorithms included in Flink ML 2.1 release and achieve performance parity with Spark Key: FLINK-27096 URL: https://issues.apache.org/jira/browse/FLINK-27096

[jira] [Created] (FLINK-26828) build flink-ml example module

2022-03-23 Thread Jing Ge (Jira)
Jing Ge created FLINK-26828: --- Summary: build flink-ml example module Key: FLINK-26828 URL: https://issues.apache.org/jira/browse/FLINK-26828 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-26404) Currently, Flink-ML only supports local file systems

2022-02-28 Thread mumu (Jira)
mumu created FLINK-26404: Summary: Currently, Flink-ML only supports local file systems Key: FLINK-26404 URL: https://issues.apache.org/jira/browse/FLINK-26404 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26313) Support Online KMeans in Flink ML

2022-02-22 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-26313: Summary: Support Online KMeans in Flink ML Key: FLINK-26313 URL: https://issues.apache.org/jira/browse/FLINK-26313 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-26100) Set up Flink ML Document Website

2022-02-13 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-26100: Summary: Set up Flink ML Document Website Key: FLINK-26100 URL: https://issues.apache.org/jira/browse/FLINK-26100 Project: Flink Issue Type: New Feature

Re: [ANNOUNCE] Apache Flink ML 2.0.0 released

2022-01-10 Thread Till Rohrmann
D. > > On Fri, Jan 7, 2022 at 2:27 PM Yun Gao wrote: > >> The Apache Flink community is very happy to announce the release of >> Apache Flink ML 2.0.0. >> >> >> >> Apache Flink ML provides API and infrastructure that simplifies >> implementing d

Re: [ANNOUNCE] Apache Flink ML 2.0.0 released

2022-01-07 Thread David Morávek
Great job! <3 Thanks Dong and Yun for managing the release and big thanks to everyone who has contributed! Best, D. On Fri, Jan 7, 2022 at 2:27 PM Yun Gao wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink ML 2.0.0. > > > > Apache

[ANNOUNCE] Apache Flink ML 2.0.0 released

2022-01-07 Thread Yun Gao
The Apache Flink community is very happy to announce the release of Apache Flink ML 2.0.0. Apache Flink ML provides API and infrastructure that simplifies implementing distributed ML algorithms, and it also provides a library of off-the-shelf ML algorithms. Please check out the release blog

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

2022-01-05 Thread Yun Gao
I'm happy to announce that we have unanimously approved this release. There are 6 approving votes, 3 of which are binding: * Dong Lin (non-binding) * Zhipeng Zhang (non-binding) * Xingbo Huang (non-binding) * Till Rohrmann (binding) * Dian Fu (binding) * Becket Qin (binding) There are no disapp

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

2022-01-05 Thread Yun Gao
Very thanks everyone for the verification! I'll announce the result in a separate thread. Best, Yun -- Sender:Becket Qin Date:2022/01/05 23:16:26 Recipient:dev Cc:Yun Gao Theme:Re: [VOTE] Apache Flink ML Release 2.0.0, re

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

2022-01-05 Thread Becket Qin
ng Python 3.9 (or later > versions) > > with pip3. The issue could be fixed by using e.g. Python 3.8. > > > > The supported python versions are documented in flink-ml-python/README.md > > but we forgot to enforce this check in the setup.py previously. We have > > me

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

2022-01-05 Thread Dian Fu
d python versions are documented in flink-ml-python/README.md > but we forgot to enforce this check in the setup.py previously. We have > merged PR (link <https://github.com/apache/flink-ml/pull/51>) to improve > the error message in the master branch. > > > > > On

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

2022-01-03 Thread Dong Lin
-ml-python/README.md but we forgot to enforce this check in the setup.py previously. We have merged PR (link <https://github.com/apache/flink-ml/pull/51>) to improve the error message in the master branch. On Mon, Jan 3, 2022 at 10:10 PM Till Rohrmann wrote: > +1 (binding) > >

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

2022-01-03 Thread Till Rohrmann
this part if not already done. Cheers, Till On Fri, Dec 31, 2021 at 10:16 AM Xingbo Huang wrote: > +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 >

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 (

  1   2   3   4   >