[jira] [Created] (FLINK-35166) Improve the performance of Hybrid Shuffle when enable memory decoupling

Jiang Xin created FLINK-35166: - Summary: Improve the performance of Hybrid Shuffle when enable memory decoupling Key: FLINK-35166 URL: https://issues.apache.org/jira/browse/FLINK-35166 Project: Flink

[jira] [Created] (FLINK-33961) Hybrid Shuffle may hang when exclusive buffers per channel is set to 0

Jiang Xin created FLINK-33961: - Summary: Hybrid Shuffle may hang when exclusive buffers per channel is set to 0 Key: FLINK-33961 URL: https://issues.apache.org/jira/browse/FLINK-33961 Project: Flink

[jira] [Created] (FLINK-33954) Large record may cause the hybrid shuffle hang

Jiang Xin created FLINK-33954: - Summary: Large record may cause the hybrid shuffle hang Key: FLINK-33954 URL: https://issues.apache.org/jira/browse/FLINK-33954 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33879) Hybrid Shuffle may hang during redistribution

Jiang Xin created FLINK-33879: - Summary: Hybrid Shuffle may hang during redistribution Key: FLINK-33879 URL: https://issues.apache.org/jira/browse/FLINK-33879 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33668) Decoupling Shuffle network memory and job topology

Jiang Xin created FLINK-33668: - Summary: Decoupling Shuffle network memory and job topology Key: FLINK-33668 URL: https://issues.apache.org/jira/browse/FLINK-33668 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-33118) Remove the PythonBridgeUtils

Jiang Xin created FLINK-33118: - Summary: Remove the PythonBridgeUtils Key: FLINK-33118 URL: https://issues.apache.org/jira/browse/FLINK-33118 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-32911) Release Testing: Verify FLINK-28386: Trigger an immediate checkpoint after all sinks finished

Jiang Xin created FLINK-32911: - Summary: Release Testing: Verify FLINK-28386: Trigger an immediate checkpoint after all sinks finished Key: FLINK-32911 URL: https://issues.apache.org/jira/browse/FLINK-32911

[jira] [Created] (FLINK-32704) Supports spilling to disk when feedback channel memory buffer is full

Jiang Xin created FLINK-32704: - Summary: Supports spilling to disk when feedback channel memory buffer is full Key: FLINK-32704 URL: https://issues.apache.org/jira/browse/FLINK-32704 Project: Flink

[jira] [Created] (FLINK-32603) Avoid consuming twice when two pipelines have the same table source

Jiang Xin created FLINK-32603: - Summary: Avoid consuming twice when two pipelines have the same table source Key: FLINK-32603 URL: https://issues.apache.org/jira/browse/FLINK-32603 Project: Flink

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

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 Issu

[jira] [Created] (FLINK-32545) Removes the expensive Row operations like join

Jiang Xin created FLINK-32545: - Summary: Removes the expensive Row operations like join Key: FLINK-32545 URL: https://issues.apache.org/jira/browse/FLINK-32545 Project: Flink Issue Type: Improvem

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

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:

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

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

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-31948) Supports triggering CI manually

Jiang Xin created FLINK-31948: - Summary: Supports triggering CI manually Key: FLINK-31948 URL: https://issues.apache.org/jira/browse/FLINK-31948 Project: Flink Issue Type: Improvement C

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

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

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

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

[jira] [Created] (FLINK-31486) Using KeySelector in IterationBody causes ClassNotFoundException

Jiang Xin created FLINK-31486: - Summary: Using KeySelector in IterationBody causes ClassNotFoundException Key: FLINK-31486 URL: https://issues.apache.org/jira/browse/FLINK-31486 Project: Flink I

[jira] [Created] (FLINK-31453) Improve the test utils to call methods explicitly

Jiang Xin created FLINK-31453: - Summary: Improve the test utils to call methods explicitly Key: FLINK-31453 URL: https://issues.apache.org/jira/browse/FLINK-31453 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-31422) Add Servable for Logistic Regression Model

Jiang Xin created FLINK-31422: - Summary: Add Servable for Logistic Regression Model Key: FLINK-31422 URL: https://issues.apache.org/jira/browse/FLINK-31422 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31312) EnableObjectReuse cause different behaviors

Jiang Xin created FLINK-31312: - Summary: EnableObjectReuse cause different behaviors Key: FLINK-31312 URL: https://issues.apache.org/jira/browse/FLINK-31312 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31306) Add Servable for PipelineModel

Jiang Xin created FLINK-31306: - Summary: Add Servable for PipelineModel Key: FLINK-31306 URL: https://issues.apache.org/jira/browse/FLINK-31306 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-31240) Reduce the overhead of conversion between DataStream and Table

Jiang Xin created FLINK-31240: - Summary: Reduce the overhead of conversion between DataStream and Table Key: FLINK-31240 URL: https://issues.apache.org/jira/browse/FLINK-31240 Project: Flink Iss

[jira] [Created] (FLINK-30715) FLIP-289: Support Online Inference

Jiang Xin created FLINK-30715: - Summary: FLIP-289: Support Online Inference Key: FLINK-30715 URL: https://issues.apache.org/jira/browse/FLINK-30715 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30515) Add benchmark for CountVectorizer, Imputer, RobustScaler, UnivariateFeatureSelector and VarianceThresholdSelector

Jiang Xin created FLINK-30515: - Summary: Add benchmark for CountVectorizer, Imputer, RobustScaler, UnivariateFeatureSelector and VarianceThresholdSelector Key: FLINK-30515 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-30420) NPE thrown when using window time in Table API

Jiang Xin created FLINK-30420: - Summary: NPE thrown when using window time in Table API Key: FLINK-30420 URL: https://issues.apache.org/jira/browse/FLINK-30420 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30160) Add Transformer for FValueTest

Jiang Xin created FLINK-30160: - Summary: Add Transformer for FValueTest Key: FLINK-30160 URL: https://issues.apache.org/jira/browse/FLINK-30160 Project: Flink Issue Type: Sub-task Compo

[jira] [Created] (FLINK-30159) Add Transformer for ANOVATest

Jiang Xin created FLINK-30159: - Summary: Add Transformer for ANOVATest Key: FLINK-30159 URL: https://issues.apache.org/jira/browse/FLINK-30159 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-30014) Fix the NPE from aggregate util

Jiang Xin created FLINK-30014: - Summary: Fix the NPE from aggregate util Key: FLINK-30014 URL: https://issues.apache.org/jira/browse/FLINK-30014 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-29786) VarianceThresholdSelector Uses FeaturesCol as Input Param

Jiang Xin created FLINK-29786: - Summary: VarianceThresholdSelector Uses FeaturesCol as Input Param Key: FLINK-29786 URL: https://issues.apache.org/jira/browse/FLINK-29786 Project: Flink Issue Typ

[jira] [Created] (FLINK-29593) Add Approximate Quantile Util

Jiang Xin created FLINK-29593: - Summary: Add Approximate Quantile Util Key: FLINK-29593 URL: https://issues.apache.org/jira/browse/FLINK-29593 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-29592) Add Transformer and Estimator for RobustScaler

Jiang Xin created FLINK-29592: - Summary: Add Transformer and Estimator for RobustScaler Key: FLINK-29592 URL: https://issues.apache.org/jira/browse/FLINK-29592 Project: Flink Issue Type: New Feat

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

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 Feat

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

Jiang Xin created FLINK-29409: - Summary: Add Transformer and Estimator for VarianceThresholdSelector Key: FLINK-29409 URL: https://issues.apache.org/jira/browse/FLINK-29409 Project: Flink Issue