[jira] [Created] (FLINK-32598) Spill data from feedback edge to disk to avoid possible OOM

2023-07-17 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-32598: - Summary: Spill data from feedback edge to disk to avoid possible OOM Key: FLINK-32598 URL: https://issues.apache.org/jira/browse/FLINK-32598 Project: Flink

[jira] [Created] (FLINK-32293) Support vector with long index

2023-06-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-32293: - Summary: Support vector with long index Key: FLINK-32293 URL: https://issues.apache.org/jira/browse/FLINK-32293 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-32292) TableUtils.getRowTypeInfo fails to get type information of Tuple

2023-06-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-32292: - Summary: TableUtils.getRowTypeInfo fails to get type information of Tuple Key: FLINK-32292 URL: https://issues.apache.org/jira/browse/FLINK-32292 Project: Flink

[jira] [Created] (FLINK-31910) Using BroadcastUtils#withBroadcast in iteration perround mode got stuck

2023-04-24 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31910: - Summary: Using BroadcastUtils#withBroadcast in iteration perround mode got stuck Key: FLINK-31910 URL: https://issues.apache.org/jira/browse/FLINK-31910 Project:

[jira] [Created] (FLINK-31909) Using BroadcastUtils#withBroadcast in iteration perround mode got stuck

2023-04-24 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31909: - Summary: Using BroadcastUtils#withBroadcast in iteration perround mode got stuck Key: FLINK-31909 URL: https://issues.apache.org/jira/browse/FLINK-31909 Project:

[jira] [Created] (FLINK-31903) Caching records fails in BroadcastUtils#withBroadcastStream

2023-04-24 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31903: - Summary: Caching records fails in BroadcastUtils#withBroadcastStream Key: FLINK-31903 URL: https://issues.apache.org/jira/browse/FLINK-31903 Project: Flink

[jira] [Created] (FLINK-31901) AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records

2023-04-24 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31901: - Summary: AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records Key: FLINK-31901 URL:

[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

[jira] [Created] (FLINK-31410) ListStateWithCache Should support incremental snapshot

2023-03-12 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31410: - Summary: ListStateWithCache Should support incremental snapshot Key: FLINK-31410 URL: https://issues.apache.org/jira/browse/FLINK-31410 Project: Flink

[jira] [Created] (FLINK-31374) ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

2023-03-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31374: - Summary: ProxyStreamPartitioner should implement ConfigurableStreamPartitioner Key: FLINK-31374 URL: https://issues.apache.org/jira/browse/FLINK-31374 Project:

[jira] [Created] (FLINK-31373) PerRoundWrapperOperator should carry epoch information in watermark

2023-03-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31373: - Summary: PerRoundWrapperOperator should carry epoch information in watermark Key: FLINK-31373 URL: https://issues.apache.org/jira/browse/FLINK-31373 Project: Flink

[jira] [Created] (FLINK-31276) VectorIndexerTest#testFitAndPredictWithHandleInvalid fails

2023-03-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31276: - Summary: VectorIndexerTest#testFitAndPredictWithHandleInvalid fails Key: FLINK-31276 URL: https://issues.apache.org/jira/browse/FLINK-31276 Project: Flink

[jira] [Created] (FLINK-31255) OperatorUtils#createWrappedOperatorConfig fails to wrap operator config

2023-02-28 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31255: - Summary: OperatorUtils#createWrappedOperatorConfig fails to wrap operator config Key: FLINK-31255 URL: https://issues.apache.org/jira/browse/FLINK-31255 Project:

[jira] [Created] (FLINK-31191) VectorIndexer should check whether doublesByColumn is null before snapshot

2023-02-22 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31191: - Summary: VectorIndexer should check whether doublesByColumn is null before snapshot Key: FLINK-31191 URL: https://issues.apache.org/jira/browse/FLINK-31191

[jira] [Created] (FLINK-31173) TailOperator should only have one input

2023-02-21 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31173: - Summary: TailOperator should only have one input Key: FLINK-31173 URL: https://issues.apache.org/jira/browse/FLINK-31173 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31160) Support join/cogroup in BroadcastUtils.withBroadcastStream

2023-02-20 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31160: - Summary: Support join/cogroup in BroadcastUtils.withBroadcastStream Key: FLINK-31160 URL: https://issues.apache.org/jira/browse/FLINK-31160 Project: Flink

[jira] [Created] (FLINK-30933) Result of join inside iterationBody loses max watermark

2023-02-06 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30933: - Summary: Result of join inside iterationBody loses max watermark Key: FLINK-30933 URL: https://issues.apache.org/jira/browse/FLINK-30933 Project: Flink

[jira] [Created] (FLINK-30671) Add AlgoOperator for ClusteringEvaluator

2023-01-12 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30671: - Summary: Add AlgoOperator for ClusteringEvaluator Key: FLINK-30671 URL: https://issues.apache.org/jira/browse/FLINK-30671 Project: Flink Issue Type:

[jira] [Created] (FLINK-30566) Add benchmark configurations for agglomerativeclustering, hashingtf, idf, kbinsdiscretizer, linearregression, linearsvc, logisticregression, ngram, regextokenizer, toke

2023-01-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30566: - Summary: Add benchmark configurations for agglomerativeclustering, hashingtf, idf, kbinsdiscretizer, linearregression, linearsvc, logisticregression, ngram, regextokenizer, tokenizer and vectorindexer

[jira] [Created] (FLINK-30541) Add Transformer and Estimator for OnlineStandardScaler

2023-01-02 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30541: - Summary: Add Transformer and Estimator for OnlineStandardScaler Key: FLINK-30541 URL: https://issues.apache.org/jira/browse/FLINK-30541 Project: Flink

[jira] [Created] (FLINK-30451) Add Estimator and Transformer for Swing

2022-12-18 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30451: - Summary: Add Estimator and Transformer for Swing Key: FLINK-30451 URL: https://issues.apache.org/jira/browse/FLINK-30451 Project: Flink Issue Type: New

[jira] [Created] (FLINK-30249) TableUtils.getRowTypeInfo() creating wrong TypeInformation

2022-11-30 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30249: - Summary: TableUtils.getRowTypeInfo() creating wrong TypeInformation Key: FLINK-30249 URL: https://issues.apache.org/jira/browse/FLINK-30249 Project: Flink

[jira] [Created] (FLINK-29911) Improve performance of AgglomerativeClustering

2022-11-06 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29911: - Summary: Improve performance of AgglomerativeClustering Key: FLINK-29911 URL: https://issues.apache.org/jira/browse/FLINK-29911 Project: Flink Issue Type:

[jira] [Created] (FLINK-29824) AgglomerativeClustering fails when the distanceThreshold is very large

2022-10-31 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29824: - Summary: AgglomerativeClustering fails when the distanceThreshold is very large Key: FLINK-29824 URL: https://issues.apache.org/jira/browse/FLINK-29824 Project:

[jira] [Created] (FLINK-29176) Add python source/test for ChiSqTest

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29176: - Summary: Add python source/test for ChiSqTest Key: FLINK-29176 URL: https://issues.apache.org/jira/browse/FLINK-29176 Project: Flink Issue Type:

[jira] [Created] (FLINK-29175) Add documents for AgglomerativeClustering, KbinsCretizer, ChisquaredTest, VectorIndexer, Tokenizer, RegexTokenizer, IDF

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29175: - Summary: Add documents for AgglomerativeClustering, KbinsCretizer, ChisquaredTest, VectorIndexer, Tokenizer, RegexTokenizer, IDF Key: FLINK-29175 URL:

[jira] [Created] (FLINK-29174) Add document for ML algorithms

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29174: - Summary: Add document for ML algorithms Key: FLINK-29174 URL: https://issues.apache.org/jira/browse/FLINK-29174 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29170) Add Transformer and Estimator for VarianceThresholdSelector

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29170: - Summary: Add Transformer and Estimator for VarianceThresholdSelector Key: FLINK-29170 URL: https://issues.apache.org/jira/browse/FLINK-29170 Project: Flink

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

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29169: - Summary: Add Transformer and Estimator for UnivariateFeatureSelector Key: FLINK-29169 URL: https://issues.apache.org/jira/browse/FLINK-29169 Project: Flink

[jira] [Created] (FLINK-29168) Add Transformer for NGram

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29168: - Summary: Add Transformer for NGram Key: FLINK-29168 URL: https://issues.apache.org/jira/browse/FLINK-29168 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28906) Add AlgoOperator for AgglomerativeClustering

2022-08-10 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28906: - Summary: Add AlgoOperator for AgglomerativeClustering Key: FLINK-28906 URL: https://issues.apache.org/jira/browse/FLINK-28906 Project: Flink Issue Type:

[jira] [Created] (FLINK-28806) Add Estimator and Transformer for IDF

2022-08-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28806: - Summary: Add Estimator and Transformer for IDF Key: FLINK-28806 URL: https://issues.apache.org/jira/browse/FLINK-28806 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28805) Add Transformer for HashingTF

2022-08-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28805: - Summary: Add Transformer for HashingTF Key: FLINK-28805 URL: https://issues.apache.org/jira/browse/FLINK-28805 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28803) Add Transformer and Estimator for KBinsDiscretizer

2022-08-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28803: - Summary: Add Transformer and Estimator for KBinsDiscretizer Key: FLINK-28803 URL: https://issues.apache.org/jira/browse/FLINK-28803 Project: Flink Issue

[jira] [Created] (FLINK-28739) Illegal State for checkpoint in LogisticRegressionTest.test_get_model_data

2022-07-29 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28739: - Summary: Illegal State for checkpoint in LogisticRegressionTest.test_get_model_data Key: FLINK-28739 URL: https://issues.apache.org/jira/browse/FLINK-28739

[jira] [Created] (FLINK-28684) NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot

2022-07-25 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28684: - Summary: NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot Key: FLINK-28684 URL: https://issues.apache.org/jira/browse/FLINK-28684 Project:

[jira] [Created] (FLINK-28502) Add Transformer for RegexTokenizer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28502: - Summary: Add Transformer for RegexTokenizer Key: FLINK-28502 URL: https://issues.apache.org/jira/browse/FLINK-28502 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28501) Add Transformer and Estimator for VectorIndexer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28501: - Summary: Add Transformer and Estimator for VectorIndexer Key: FLINK-28501 URL: https://issues.apache.org/jira/browse/FLINK-28501 Project: Flink Issue

[jira] [Created] (FLINK-28500) Add Transformer for Tokenizer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28500: - Summary: Add Transformer for Tokenizer Key: FLINK-28500 URL: https://issues.apache.org/jira/browse/FLINK-28500 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-27952) Table UDF fails when using Double.POSITIVE_INFINITY as parameters

2022-06-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27952: - Summary: Table UDF fails when using Double.POSITIVE_INFINITY as parameters Key: FLINK-27952 URL: https://issues.apache.org/jira/browse/FLINK-27952 Project: Flink

[jira] [Created] (FLINK-27877) Improve performance of several feature engineering algorithms

2022-06-02 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27877: - Summary: Improve performance of several feature engineering algorithms Key: FLINK-27877 URL: https://issues.apache.org/jira/browse/FLINK-27877 Project: Flink

[jira] [Created] (FLINK-27826) Support machine learning training for high dimesional models

2022-05-28 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27826: - Summary: Support machine learning training for high dimesional models Key: FLINK-27826 URL: https://issues.apache.org/jira/browse/FLINK-27826 Project: Flink

[jira] [Created] (FLINK-27072) Add Bucketizer in FlinkML

2022-04-06 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27072: - Summary: Add Bucketizer in FlinkML Key: FLINK-27072 URL: https://issues.apache.org/jira/browse/FLINK-27072 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-26801) LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next res...

2022-03-22 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-26801: - Summary: LogisticRegressionTest.testGetModelData» Runtime Failed to fetch next res... Key: FLINK-26801 URL: https://issues.apache.org/jira/browse/FLINK-26801

[jira] [Created] (FLINK-26626) Add Estimator and Transformer of StandardScaler in FlinkML

2022-03-14 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-26626: - Summary: Add Estimator and Transformer of StandardScaler in FlinkML Key: FLINK-26626 URL: https://issues.apache.org/jira/browse/FLINK-26626 Project: Flink

[jira] [Created] (FLINK-26443) Add a benchmark framework for flinkml

2022-03-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-26443: - Summary: Add a benchmark framework for flinkml Key: FLINK-26443 URL: https://issues.apache.org/jira/browse/FLINK-26443 Project: Flink Issue Type: New

[jira] [Created] (FLINK-25527) Add StringIndexer in FlinkML

2022-01-05 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-25527: - Summary: Add StringIndexer in FlinkML Key: FLINK-25527 URL: https://issues.apache.org/jira/browse/FLINK-25527 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-25424) Checkpointing is currently not supported for operators that implement InputSelectable

2021-12-22 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-25424: - Summary: Checkpointing is currently not supported for operators that implement InputSelectable Key: FLINK-25424 URL: https://issues.apache.org/jira/browse/FLINK-25424

[jira] [Created] (FLINK-24845) Add allreduce utility function in FlinkML

2021-11-09 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-24845: - Summary: Add allreduce utility function in FlinkML Key: FLINK-24845 URL: https://issues.apache.org/jira/browse/FLINK-24845 Project: Flink Issue Type: New

[jira] [Created] (FLINK-24838) Add BaseAlgoImpl class to support link() and linkFrom()

2021-11-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-24838: - Summary: Add BaseAlgoImpl class to support link() and linkFrom() Key: FLINK-24838 URL: https://issues.apache.org/jira/browse/FLINK-24838 Project: Flink

[jira] [Created] (FLINK-24556) Support Logistic Regression in FlinkML

2021-10-14 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-24556: - Summary: Support Logistic Regression in FlinkML Key: FLINK-24556 URL: https://issues.apache.org/jira/browse/FLINK-24556 Project: Flink Issue Type: New