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

2024-11-24 Thread Yunfeng Zhou (Jira)
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

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

2024-11-03 Thread Yunfeng Zhou (Jira)
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: Fl

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

2024-04-09 Thread Yunfeng Zhou (Jira)
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 Type

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

2024-02-26 Thread Yunfeng Zhou (Jira)
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-34371) FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-02-05 Thread Yunfeng Zhou (Jira)
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-34077) Sphinx version needs upgrade

2024-01-14 Thread Yunfeng Zhou (Jira)
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 Compon

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

2023-07-03 Thread Yunfeng Zhou (Jira)
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-32494) Cannot convert list literal to Table with PyFlink

2023-06-29 Thread Yunfeng Zhou (Jira)
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-32464) AssertionError when converting between Table and SQL with selection and type cast

2023-06-28 Thread Yunfeng Zhou (Jira)
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 Pro

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

2023-03-24 Thread Yunfeng Zhou (Jira)
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: Improveme

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

2023-02-07 Thread Yunfeng Zhou (Jira)
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 Issue Ty

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

2023-01-19 Thread Yunfeng Zhou (Jira)
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: Improv

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

2022-12-28 Thread Yunfeng Zhou (Jira)
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-30292) Better support for conversion between DataType and TypeInformation

2022-12-04 Thread Yunfeng Zhou (Jira)
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-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 Type

[jira] [Created] (FLINK-30168) PyFlink Deserialization Error with Object Array

2022-11-23 Thread Yunfeng Zhou (Jira)
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: I

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

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

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

2022-11-21 Thread Yunfeng Zhou (Jira)
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 Compone

[jira] [Created] (FLINK-30124) GenericType is not supported in PyFlink currently

2022-11-21 Thread Yunfeng Zhou (Jira)
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 Type

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

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

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

2022-11-13 Thread Yunfeng Zhou (Jira)
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: Flink

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

2022-11-01 Thread Yunfeng Zhou (Jira)
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 Issu

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

2022-10-25 Thread Yunfeng Zhou (Jira)
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-29604) Add Estimator and Transformer for CountVectorizer

2022-10-12 Thread Yunfeng Zhou (Jira)
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-29602) Add Transformer for SQLTransformer

2022-10-12 Thread Yunfeng Zhou (Jira)
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-29603) Add Transformer for StopWordsRemover

2022-10-12 Thread Yunfeng Zhou (Jira)
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-29600) Add Estimator and Transformer for BucketedRandomProjectionLSH

2022-10-12 Thread Yunfeng Zhou (Jira)
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-29601) Add Estimator and Transformer for UnivariateFeatureSelector

2022-10-12 Thread Yunfeng Zhou (Jira)
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-29599) Add Estimator and Transformer for MinHashLSH

2022-10-12 Thread Yunfeng Zhou (Jira)
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-29598) Add Estimator and Transformer for Imputer

2022-10-12 Thread Yunfeng Zhou (Jira)
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 Fea

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

2022-10-12 Thread Yunfeng Zhou (Jira)
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 T

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

2022-10-12 Thread Yunfeng Zhou (Jira)
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 Fe

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

2022-10-12 Thread Yunfeng Zhou (Jira)
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: N

[jira] [Created] (FLINK-29591) Add built-in UDFs to convert between arrays and vectors

2022-10-11 Thread Yunfeng Zhou (Jira)
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 Issue

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

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

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

2022-08-19 Thread Yunfeng Zhou (Jira)
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 Com

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

2022-08-19 Thread Yunfeng Zhou (Jira)
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-28941) Savepoint ignores MaxConcurrentCheckpoint limit in aligned checkpoint case

2022-08-11 Thread Yunfeng Zhou (Jira)
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: F

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

2022-08-01 Thread Yunfeng Zhou (Jira)
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-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

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

2022-07-21 Thread Yunfeng Zhou (Jira)
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-28606) Preserve distributed consistency of OperatorEvents from OperatorCoordinator to subtasks

2022-07-19 Thread Yunfeng Zhou (Jira)
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-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 Issu

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

2022-05-26 Thread Yunfeng Zhou (Jira)
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 Project

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

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

2022-04-06 Thread Yunfeng Zhou (Jira)
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-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-26263) Check data size in LogisticRegression

2022-02-20 Thread Yunfeng Zhou (Jira)
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-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

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

2021-11-18 Thread Yunfeng Zhou (Jira)
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-24817) Support Naive Bayes algorithm in Flink ML

2021-11-08 Thread Yunfeng Zhou (Jira)
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 Fea

[jira] [Created] (FLINK-22689) Table API Documentation Row-Based Operations Example Fails

2021-05-17 Thread Yunfeng Zhou (Jira)
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 Is