[DISCUSS] FLIP-309: Enable operators to trigger checkpoints dynamically

Hi all, Dong(cc'ed) and I are opening this thread to discuss our proposal to support dynamically triggering checkpoints from operators, which has been documented in FLIP-309 . With the help of the ability proposed in this

[DISCUSS] FLIP-325: Support configuring end-to-end allowed latency

Hi all, Dong(cc'ed) and I are opening this thread to discuss our proposal to support configuring end-to-end allowed latency for Flink jobs, which has been documented in FLIP-325 . By conf

[DISCUSS] FLIP-330: Support specifying record timestamp requirement

Hi all, Dong(cc'ed) and I are opening this thread to discuss our proposal to support optimizing StreamRecord's serialization performance. Currently, a StreamRecord would be converted into a 1-byte tag (+ 8-byte timestamp) + N-byte serialized value during the serialization process. In scenarios wh

Re: [DISCUSS] FLIP-330: Support specifying record timestamp requirement

the FLIP > 2. about the benchmark example, why did you enable object reuse? Since It > is an optimization of serde, will the benchmark be better if it is > disabled? > > Best regards, > Jing > > On Mon, Jul 10, 2023 at 11:54 AM Yunfeng Zhou > wrote: > > > H

Re: [DISCUSS] FLIP-330: Support specifying record timestamp requirement

hether the solution design can retain the capability of > the latency marker; > 3. The data of the POC test is of long type. Here I want to see how much > profit it will have if it is a string with a length of 100B or 1KB. > > > -- > > Best, > Matt Wang > > > --

Re: [DISCUSS] FLIP-330: Support specifying record timestamp requirement

f the latency maker cannot be used, it will greatly > > limit > > > the usage scenarios. Whether the solution design can retain the > > capability > > > of the latency marker; > > > 3. The data of the POC test is of long type. Here I want to see how much > > > pro

Re: [DISCUSS] FLIP-330: Support specifying record timestamp requirement

he latencyTrackingInterval is set too small(like 5ms), it will have a large > impact on performance. But if the latencyTrackingInterval is configured to be > relatively large, such as 10s, this impact can be ignored. > > > > -- > > Best, > Matt Wang > > > R

Re: [DISCUSS] FLIP-330: Support specifying record timestamp requirement

n type record. WordCount (where the record size is just 1 > string token + 1 integer, typically 20B or so?) shows only 2-3% throughput > improvement. Not even mention the workloads with larger record size or > higher computation load. > > Given the above, I personally don't

[DISCUSS] FLIP-365: Introduce flush interval to adjust the interval of emitting results with idempotent semantics

Hi all, Dong(cc'ed) and I are opening this thread to discuss our proposal to support buffering & flushing the output of operators with idempotent semantics, which has been documented in FLIP-365

Re: [DISCUSS] FLIP-365: Introduce flush interval to adjust the interval of emitting results with idempotent semantics

lso > requires more CPU resources for checkpointing and compaction. > > > Looking forward to your thoughts. > > > Best, > Zakelly > > > On Mon, Sep 11, 2023 at 1:39 PM Yunfeng Zhou > wrote: > > > > Hi all, > > > > Dong(cc'ed) and I

Re: Fink 1.17 vs 1.18

Hi Amir, You can find the major differences in Flink 1.18's release note[1], which has also described the performance improvements in 1.18. [1] https://flink.apache.org/2023/10/24/announcing-the-release-of-apache-flink-1.18/ Best, Yunfeng Zhou On Wed, Nov 8, 2023 at 11:50 PM Amir Ho

Re: [DISCUSS] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

forward to discussing these questions with you. Best regards, Yunfeng Zhou On Tue, Dec 26, 2023 at 2:44 PM weijie guo wrote: > > Hi devs, > > > I'd like to start a discussion about FLIP-409: DataStream V2 Building > Blocks: DataStream, Partitioning and ProcessFunction [1].

Re: [DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

ty of configurations. Looking forward to your response. Best regards, Yunfeng Zhou On Tue, Dec 26, 2023 at 2:47 PM weijie guo wrote: > > Hi devs, > > > I'd like to start a discussion about FLIP-410: Config, Context and > Processing Timer Service of DataStream API V2 [1]. This is

Re: [DISCUSS] FLIP-423 ～FLIP-428: Introduce Disaggregated State Storage and Management in Flink 2.0

t;timers can be stored on the JVM heap or RocksDB", the link points to a document in flink-1.15. It might be better to verify the referenced content is still valid in the latest Flink and update the link accordingly. Same for other references if any. Best, Yunfeng Zhou On Thu, Feb 29,

Re: [DISCUSS] FLIP-423 ～FLIP-428: Introduce Disaggregated State Storage and Management in Flink 2.0

;> > >> > Your concerns are very reasonable. Faster checkpointing is always a core >> > advantage of disaggregated state, but only for the async phase. There will >> > be some complexity introduced by in-flight requests, but I'd suggest a >> > checkpoint

Re: [DISCUSS] FLIP-423 ～FLIP-428: Introduce Disaggregated State Storage and Management in Flink 2.0

ut would better be > redefined. I suggest we discuss these existing metrics as well as some new > metrics that should be introduced in FLIP-431 later in milestone 2, since we > have basically finished the framework thus we will have a better view of what > metrics should be like after

Re: [DISCUSS] FLIP-424: Asynchronous State APIs

nc", and the existing state APIs to "org.apache.flink.api.common.state" or "org.apache.flink.api.common.state.sync". Best regards, Yunfeng Zhou On Thu, Mar 7, 2024 at 4:48 PM Zakelly Lan wrote: > > Hi devs, > > I'd like to start a discussion on a sub-FLIP of FLIP-423: Disag

Re: [DISCUSS] FLIP-424: Asynchronous State APIs

od package names. While for state APIs, we > should stay in the flink-core(-api) module alongside with other > apis, currently I tend to compromise at the expense of naming style. > > > Looking forward to hearing from you again! > > Thanks & Best, > Zakelly > > On

Re: [DISCUSS] FLIP-424: Asynchronous State APIs

treamOperatorV2, the current package name would be acceptable >> to me if other reviewers of this FLIP agrees on it. > > Actually, I don't like 'v2' either. So if there is another good name, I'd be > happy to apply. This is a compromise to the current situation. M

Re: [DISCUSS] FLIP-423 ～FLIP-428: Introduce Disaggregated State Storage and Management in Flink 2.0

; > > > > > > On Wed, Mar 6, 2024 at 5:34 PM Gyula Fóra > > > > > wrote: > > > > > > > > > > > > > > > Hey all! > > > > > > > > > > > > > > >

Re: [VOTE] FLIP-433: State Access on DataStream API V2

+1 (non-binding) Best, Yunfeng On Wed, Mar 20, 2024 at 8:29 PM weijie guo wrote: > > Hi everyone, > > > Thanks for all the feedback about the FLIP-433: State Access on > DataStream API V2 [1]. The discussion thread is here [2]. > > > The vote will be open for at least 72 hours unless there is an

Re: [VOTE] FLIP-425: Asynchronous Execution Model

+1 (non-bindling) Best, Yunfeng On Wed, Mar 27, 2024 at 6:28 PM Yanfei Lei wrote: > > Hi everyone, > > Thanks for all the feedback about the FLIP-425: Asynchronous Execution > Model [1]. The discussion thread is here [2]. > > The vote will be open for at least 72 hours unless there is an > objec

Re: [VOTE] FLIP-424: Asynchronous State APIs

+1 (non-binding) Best, Yunfeng On Wed, Mar 27, 2024 at 6:23 PM Zakelly Lan wrote: > > Hi devs, > > I'd like to start a vote on the FLIP-424: Asynchronous State APIs [1]. The > discussion thread is here [2]. > > The vote will be open for at least 72 hours unless there is an objection or > insuffi

Re: Two potential bugs in Flink ML

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

Re: Two potential bugs in Flink ML

"statedescriptor", // the state > name > BasicTypeInfo.DOUBLE_TYPE_INFO, > BasicTypeInfo.STRING_TYPE_INFO > ); >

Re: Flink stateful functions and Agentic Architecture

Hi David, I'm not very familiar with stateful functions, but I participated in Flink ML, a machine learning infrastructure and algorithm library based on Flink. There we developed functions like iteration based model-training process and hot updating ML model during online prediction. You may chec

[DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP)

Hi all， I'm opening this thread to propose the design to support multiple rule & dynamic rule changing in the Flink-CEP project, as described in FLIP-200 [1] . Currently Flink CEP only supports having a single pattern inside a CepOperator and does not support changing the pattern dynamically. In

Re: [DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP)

Hi Konstantin, Thanks for your suggestion. For the first idea, I agree that adding a timestamp field and making users able to schedule a rule is a useful feature. This might not require too much implementation work and I believe it can be achieved in this FLIP. As for the second idea, Rule is a c

Re: [DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP)

>> On Fri, 10 Dec 2021 at 13:19, Martijn Visser > > >> wrote: > > >> > > >>> Hi Yunfeng, > > >>> > > >>> Thanks for creating the FLIP. I don't see any mention of SQL's > > >>> MATCH_RECOGNIZE implementation

Re: [DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP)

and Dynamic Rule Changing . > But we are facing such a problem, some users’ usage scenarios are that they > want to have their own pattern for each user_id, which means that there > could be thousands of patterns, which would make the performance of Pattern > Matching very poor. We ar

Re: [VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML)

Excellent work to support iteration for Flink. +1 (binding) Best regards, Yunfeng On Sat, Oct 23, 2021 at 12:27 AM Till Rohrmann wrote: > Thanks for creating this FLIP. > > +1 (binding) > > Cheers, > Till > > > On Fri, Oct 22, 2021 at 6:29 AM Guowei Ma wrote: > > > +1 (binding) > > > > Best,

Re: [VOTE] FLIP-176: Unified Iteration to Support Algorithms (Flink ML)

Sorry that I misunderstood the usage of "binding". I am not a Flink committer so my vote should be a non-binding one. Best, Yunfeng On Mon, Oct 25, 2021 at 4:33 PM Yunfeng Zhou wrote: > Excellent work to support iteration for Flink. > > +1 (binding) > > Best regards,

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

Thanks for raising this release candidate. +1 (non-binding) - Verified that the checksums and GPG files match the corresponding release files. - Verified that the source distributions do not contain any binaries. - Built the source distribution and ensured that all source files have Apache header

Re: [VOTE] Release 2.0-preview1, release candidate #1

+1 (non-binding) - Verified checksums - Built from source - Reviewed release notes - Ran WordCount example and it works as expected Best, Yunfeng > 2024年10月13日 00:46，Xintong Song 写道： > > Hi everyone, > > Please review and vote on the release candidate #1 for the version > 2.0-preview1, as fo

Re: [DISCUSS] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs

Hi Zakelly, Thank for the proposal! I noticed that it says users can invoke `enableAsyncState` after sum or process, thus will this FLIP add `enableAsyncState` to `SingleOutputStreamOperator` as well? Best, Yunfeng > 2024年12月4日 20:32，Zakelly Lan 写道： > > Hi everyone, > > I'd like to start

Re: [VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs

+1(non-binding) Best, Yunfeng > 2024年12月17日 12:17，Zakelly Lan 写道： > > Hi all, > > I'd like to start a vote on FLIP-488 [1], which has been discussed here [2]. > > The vote will remain open for at least 72 hours. > > > Best, > Zakelly > > [1] https://cwiki.apache.org/confluence/x/yIrREw > [

Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks

Hi Xu Huang, I noticed your discussions mentioned that the identifier of watermarks needs to be global across the whole job. Therefore, would it be better to add to the FLIP a proposal to the naming convention of identifiers? For example, the identifiers are encouraged to be named with its hold

Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks

," such as "INTERNAL_RUNTIME_BACKLOG" or > "INTERNAL_CONNECTOR_KAFKA_IDLE." > > What do you think? I will incorporate this naming strategy into the FLIP if > you're okay with it. > > Thanks for your suggestion again! > > Best, > Xu Huang > > Yunfeng Zhou 于2024年

Re: [VOTE] FLIP-467: Introduce Generalized Watermarks

+1 (non-binding) Best, Yunfeng > 2024年12月20日 15:49，Xu Huang 写道： > > Hi, all. > > > I'd like to start a vote on FLIP-467: Introduce Generalized Watermarks [1]. > > You can find the discussion in here [2]. > > > The vote will last for at least 72 hours unless there is objection or > insuffic

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

+1 (non-binding) - Verified signatures and sha512 - Reviewed the website PR - Compiled the project with java 11 and maven 3.8.6 Best, Yunfeng > 2025年3月10日 17:05，Xintong Song 写道： > > Hi everyone, > > There were some blocker issues reported during building the RC1, when the > git tag has alread

[jira] [Created] (FLINK-32464) AssertionError when converting between Table and SQL with selection and type cast

Yunfeng Zhou created FLINK-32464: Summary: AssertionError when converting between Table and SQL with selection and type cast Key: FLINK-32464 URL: https://issues.apache.org/jira/browse/FLINK-32464

[jira] [Created] (FLINK-32494) Cannot convert list literal to Table with PyFlink

Yunfeng Zhou created FLINK-32494: Summary: Cannot convert list literal to Table with PyFlink Key: FLINK-32494 URL: https://issues.apache.org/jira/browse/FLINK-32494 Project: Flink Issue Type

[jira] [Created] (FLINK-32514) FLIP-309: Support using larger checkpointing interval when source is processing backlog

Yunfeng Zhou created FLINK-32514: Summary: FLIP-309: Support using larger checkpointing interval when source is processing backlog Key: FLINK-32514 URL: https://issues.apache.org/jira/browse/FLINK-32514

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

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-30292) Better support for conversion between DataType and TypeInformation

Yunfeng Zhou created FLINK-30292: Summary: Better support for conversion between DataType and TypeInformation Key: FLINK-30292 URL: https://issues.apache.org/jira/browse/FLINK-30292 Project: Flink

[jira] [Created] (FLINK-30532) Add benchmark for DCT, SQLTransformer and StopWordsRemover algorithm

Yunfeng Zhou created FLINK-30532: Summary: Add benchmark for DCT, SQLTransformer and StopWordsRemover algorithm Key: FLINK-30532 URL: https://issues.apache.org/jira/browse/FLINK-30532 Project: Flink

[jira] [Created] (FLINK-30753) Py4J cannot acquire Table.explain() method

Yunfeng Zhou created FLINK-30753: Summary: Py4J cannot acquire Table.explain() method Key: FLINK-30753 URL: https://issues.apache.org/jira/browse/FLINK-30753 Project: Flink Issue Type

[jira] [Created] (FLINK-30959) UNIX_TIMESTAMP's return value does not meet expected

Yunfeng Zhou created FLINK-30959: Summary: UNIX_TIMESTAMP's return value does not meet expected Key: FLINK-30959 URL: https://issues.apache.org/jira/browse/FLINK-30959 Project: Flink

[jira] [Created] (FLINK-31605) Table#to_pandas check table boundedness

Yunfeng Zhou created FLINK-31605: Summary: Table#to_pandas check table boundedness Key: FLINK-31605 URL: https://issues.apache.org/jira/browse/FLINK-31605 Project: Flink Issue Type

[jira] [Created] (FLINK-34077) Sphinx version needs upgrade

Yunfeng Zhou created FLINK-34077: Summary: Sphinx version needs upgrade Key: FLINK-34077 URL: https://issues.apache.org/jira/browse/FLINK-34077 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34371) FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

Yunfeng Zhou created FLINK-34371: Summary: FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment Key: FLINK-34371 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-34519) Refine checkpoint scheduling and canceling logic

Yunfeng Zhou created FLINK-34519: Summary: Refine checkpoint scheduling and canceling logic Key: FLINK-34519 URL: https://issues.apache.org/jira/browse/FLINK-34519 Project: Flink Issue Type

[jira] [Created] (FLINK-35066) TwoInputOperator in IterationBody cannot use keyBy

Yunfeng Zhou created FLINK-35066: Summary: TwoInputOperator in IterationBody cannot use keyBy Key: FLINK-35066 URL: https://issues.apache.org/jira/browse/FLINK-35066 Project: Flink Issue

[jira] [Created] (FLINK-27084) Perround mode recreating operator fails

Yunfeng Zhou created FLINK-27084: Summary: Perround mode recreating operator fails Key: FLINK-27084 URL: https://issues.apache.org/jira/browse/FLINK-27084 Project: Flink Issue Type: Bug

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

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-27797) PythonTableUtils.getCollectionInputFormat cannot correctly handle None values

Yunfeng Zhou created FLINK-27797: Summary: PythonTableUtils.getCollectionInputFormat cannot correctly handle None values Key: FLINK-27797 URL: https://issues.apache.org/jira/browse/FLINK-27797

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

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-26100) Set up Flink ML Document Website

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

[jira] [Created] (FLINK-26263) Check data size in LogisticRegression

Yunfeng Zhou created FLINK-26263: Summary: Check data size in LogisticRegression Key: FLINK-26263 URL: https://issues.apache.org/jira/browse/FLINK-26263 Project: Flink Issue Type: Bug

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

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-22689) Table API Documentation Row-Based Operations Example Fails

Yunfeng Zhou created FLINK-22689: Summary: Table API Documentation Row-Based Operations Example Fails Key: FLINK-22689 URL: https://issues.apache.org/jira/browse/FLINK-22689 Project: Flink

[jira] [Created] (FLINK-24817) Support Naive Bayes algorithm in Flink ML

Yunfeng Zhou created FLINK-24817: Summary: Support Naive Bayes algorithm in Flink ML Key: FLINK-24817 URL: https://issues.apache.org/jira/browse/FLINK-24817 Project: Flink Issue Type: New

[jira] [Created] (FLINK-24955) Add One-hot Encoder to Flink ML

Yunfeng Zhou created FLINK-24955: Summary: Add One-hot Encoder to Flink ML Key: FLINK-24955 URL: https://issues.apache.org/jira/browse/FLINK-24955 Project: Flink Issue Type: New Feature

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

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

[jira] [Created] (FLINK-28606) Preserve distributed consistency of OperatorEvents from OperatorCoordinator to subtasks

Yunfeng Zhou created FLINK-28606: Summary: Preserve distributed consistency of OperatorEvents from OperatorCoordinator to subtasks Key: FLINK-28606 URL: https://issues.apache.org/jira/browse/FLINK-28606

[jira] [Created] (FLINK-28639) Preserve distributed consistency of OperatorEvents from subtasks to OperatorCoordinator

Yunfeng Zhou created FLINK-28639: Summary: Preserve distributed consistency of OperatorEvents from subtasks to OperatorCoordinator Key: FLINK-28639 URL: https://issues.apache.org/jira/browse/FLINK-28639

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

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

[jira] [Created] (FLINK-28761) BinaryClassificationEvaluator cannot work with unaligned checkpoint

Yunfeng Zhou created FLINK-28761: Summary: BinaryClassificationEvaluator cannot work with unaligned checkpoint Key: FLINK-28761 URL: https://issues.apache.org/jira/browse/FLINK-28761 Project: Flink

[jira] [Created] (FLINK-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

Yunfeng Zhou created FLINK-28941: Summary: Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case Key: FLINK-28941 URL: https://issues.apache.org/jira/browse/FLINK-28941 Project

[jira] [Created] (FLINK-29043) Improve ML iteration efficiency

Yunfeng Zhou created FLINK-29043: Summary: Improve ML iteration efficiency Key: FLINK-29043 URL: https://issues.apache.org/jira/browse/FLINK-29043 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29044) Add Transformer for DCT

Yunfeng Zhou created FLINK-29044: Summary: Add Transformer for DCT Key: FLINK-29044 URL: https://issues.apache.org/jira/browse/FLINK-29044 Project: Flink Issue Type: New Feature

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

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-29429) Add DataType for Flink ML linear algorithm classes

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-29591) Add built-in UDFs to convert between arrays and vectors

Yunfeng Zhou created FLINK-29591: Summary: Add built-in UDFs to convert between arrays and vectors Key: FLINK-29591 URL: https://issues.apache.org/jira/browse/FLINK-29591 Project: Flink

[jira] [Created] (FLINK-29595) Add Estimator and Transformer for ChiSqSelector

Yunfeng Zhou created FLINK-29595: Summary: Add Estimator and Transformer for ChiSqSelector Key: FLINK-29595 URL: https://issues.apache.org/jira/browse/FLINK-29595 Project: Flink Issue Type

[jira] [Created] (FLINK-29596) Add Estimator and Transformer for RFormula

Yunfeng Zhou created FLINK-29596: Summary: Add Estimator and Transformer for RFormula Key: FLINK-29596 URL: https://issues.apache.org/jira/browse/FLINK-29596 Project: Flink Issue Type: New

[jira] [Created] (FLINK-29597) Add Estimator and Transformer for QuantileDiscretizer

Yunfeng Zhou created FLINK-29597: Summary: Add Estimator and Transformer for QuantileDiscretizer Key: FLINK-29597 URL: https://issues.apache.org/jira/browse/FLINK-29597 Project: Flink Issue

[jira] [Created] (FLINK-29598) Add Estimator and Transformer for Imputer

Yunfeng Zhou created FLINK-29598: Summary: Add Estimator and Transformer for Imputer Key: FLINK-29598 URL: https://issues.apache.org/jira/browse/FLINK-29598 Project: Flink Issue Type: New

[jira] [Created] (FLINK-29599) Add Estimator and Transformer for MinHashLSH

Yunfeng Zhou created FLINK-29599: Summary: Add Estimator and Transformer for MinHashLSH Key: FLINK-29599 URL: https://issues.apache.org/jira/browse/FLINK-29599 Project: Flink Issue Type: New

[jira] [Created] (FLINK-29601) Add Estimator and Transformer for UnivariateFeatureSelector

Yunfeng Zhou created FLINK-29601: Summary: Add Estimator and Transformer for UnivariateFeatureSelector Key: FLINK-29601 URL: https://issues.apache.org/jira/browse/FLINK-29601 Project: Flink

[jira] [Created] (FLINK-29600) Add Estimator and Transformer for BucketedRandomProjectionLSH

Yunfeng Zhou created FLINK-29600: Summary: Add Estimator and Transformer for BucketedRandomProjectionLSH Key: FLINK-29600 URL: https://issues.apache.org/jira/browse/FLINK-29600 Project: Flink

[jira] [Created] (FLINK-29603) Add Transformer for StopWordsRemover

Yunfeng Zhou created FLINK-29603: Summary: Add Transformer for StopWordsRemover Key: FLINK-29603 URL: https://issues.apache.org/jira/browse/FLINK-29603 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29602) Add Transformer for SQLTransformer

Yunfeng Zhou created FLINK-29602: Summary: Add Transformer for SQLTransformer Key: FLINK-29602 URL: https://issues.apache.org/jira/browse/FLINK-29602 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29604) Add Estimator and Transformer for CountVectorizer

Yunfeng Zhou created FLINK-29604: Summary: Add Estimator and Transformer for CountVectorizer Key: FLINK-29604 URL: https://issues.apache.org/jira/browse/FLINK-29604 Project: Flink Issue Type

[jira] [Created] (FLINK-29763) TaskManager heatbeat timeout exception in Github CI for python tests

Yunfeng Zhou created FLINK-29763: Summary: TaskManager heatbeat timeout exception in Github CI for python tests Key: FLINK-29763 URL: https://issues.apache.org/jira/browse/FLINK-29763 Project: Flink

[jira] [Created] (FLINK-29843) Euclidean Distance Measure generates NAN distance values

Yunfeng Zhou created FLINK-29843: Summary: Euclidean Distance Measure generates NAN distance values Key: FLINK-29843 URL: https://issues.apache.org/jira/browse/FLINK-29843 Project: Flink

[jira] [Created] (FLINK-30009) OperatorCoordinator.start()'s JavaDoc mismatches its behavior

Yunfeng Zhou created FLINK-30009: Summary: OperatorCoordinator.start()'s JavaDoc mismatches its behavior Key: FLINK-30009 URL: https://issues.apache.org/jira/browse/FLINK-30009 Project:

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

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-30122) Flink ML KMeans getting model data throws TypeError

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-30124) GenericType is not supported in PyFlink currently

Yunfeng Zhou created FLINK-30124: Summary: GenericType is not supported in PyFlink currently Key: FLINK-30124 URL: https://issues.apache.org/jira/browse/FLINK-30124 Project: Flink Issue

[jira] [Created] (FLINK-30130) Table.select lose watermark

Yunfeng Zhou created FLINK-30130: Summary: Table.select lose watermark Key: FLINK-30130 URL: https://issues.apache.org/jira/browse/FLINK-30130 Project: Flink Issue Type: Bug

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

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-30144) Guarantee Flink ML operators function correctly with object-reuse enabled

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-30168) PyFlink Deserialization Error with Object Array

Yunfeng Zhou created FLINK-30168: Summary: PyFlink Deserialization Error with Object Array Key: FLINK-30168 URL: https://issues.apache.org/jira/browse/FLINK-30168 Project: Flink Issue Type

[jira] [Created] (FLINK-36653) OnlineLogisticRegressionModel not updating servable and prediction result

Yunfeng Zhou created FLINK-36653: Summary: OnlineLogisticRegressionModel not updating servable and prediction result Key: FLINK-36653 URL: https://issues.apache.org/jira/browse/FLINK-36653 Project

[jira] [Created] (FLINK-36783) CTAS from VALUES throws ValidatioonException

Yunfeng Zhou created FLINK-36783: Summary: CTAS from VALUES throws ValidatioonException Key: FLINK-36783 URL: https://issues.apache.org/jira/browse/FLINK-36783 Project: Flink Issue Type: Bug