[jira] [Commented] (FLINK-38053) Release Testing: Verify FLIP-521: Integrating Variant Type into Flink

[ https://issues.apache.org/jira/browse/FLINK-38053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003982#comment-18003982 ] Yunfeng Zhou commented on FLINK-38053: -- Hi [~sxnan] [~lsy] I have verified that Fli

[jira] [Closed] (FLINK-37838) Introduce Model Function implementations based on OpenAI API

[ https://issues.apache.org/jira/browse/FLINK-37838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou closed FLINK-37838. Resolution: Duplicate Duplicated with FLINK-37799 > Introduce Model Function implementations base

[jira] [Commented] (FLINK-37799) Flink native model predict runtime implementation

[ https://issues.apache.org/jira/browse/FLINK-37799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17953974#comment-17953974 ] Yunfeng Zhou commented on FLINK-37799: -- Hi [~lihaosky], could you please assign thi

[jira] [Commented] (FLINK-37838) Introduce Model Function implementations based on OpenAI API

[ https://issues.apache.org/jira/browse/FLINK-37838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17953966#comment-17953966 ] Yunfeng Zhou commented on FLINK-37838: -- Hi [~lihaosky], I previously consulted Fang

[jira] [Updated] (FLINK-37838) Introduce Model Function implementations based on OpenAI API

[ https://issues.apache.org/jira/browse/FLINK-37838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-37838: - Fix Version/s: 2.1 > Introduce Model Function implementations based on OpenAI API >

[jira] [Created] (FLINK-37838) Introduce Model Function implementations based on OpenAI API

Yunfeng Zhou created FLINK-37838: Summary: Introduce Model Function implementations based on OpenAI API Key: FLINK-37838 URL: https://issues.apache.org/jira/browse/FLINK-37838 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-28639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938609#comment-17938609 ] Yunfeng Zhou commented on FLINK-28639: -- In fact, this issue was introduced to bette

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

[ https://issues.apache.org/jira/browse/FLINK-28639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938864#comment-17938864 ] Yunfeng Zhou commented on FLINK-28639: -- Got it. Despite that I still have some doub

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

[ https://issues.apache.org/jira/browse/FLINK-28639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17938605#comment-17938605 ] Yunfeng Zhou commented on FLINK-28639: -- Hi [~arvid] ,   Thanks for proposing an ap

[jira] [Commented] (FLINK-35810) OOM in AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry

[ https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932145#comment-17932145 ] Yunfeng Zhou commented on FLINK-35810: -- Hi all, I reproduced the bug locally and ra

[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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-34371: - Release Note: For operators that only generates outputs after all inputs have been consumed, the

[jira] [Commented] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845206#comment-17845206 ] Yunfeng Zhou commented on FLINK-35025: -- Sure. I'll submit a fix for it. > Wire Asy

[jira] [Commented] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845188#comment-17845188 ] Yunfeng Zhou commented on FLINK-35025: -- Hi [~zakelly], I just noticed that the curr

[jira] [Commented] (FLINK-35030) Introduce Epoch Manager for watermark under async execution

[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840257#comment-17840257 ] Yunfeng Zhou commented on FLINK-35030: -- [~Yanfei Lei] According to the description

[jira] [Commented] (FLINK-35031) Event timer firing under async execution model

[ https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837980#comment-17837980 ] Yunfeng Zhou commented on FLINK-35031: -- What is the relationship between this ticke

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

[ https://issues.apache.org/jira/browse/FLINK-35066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-35066: - Issue Type: Bug (was: Technical Debt) > TwoInputOperator in IterationBody cannot use keyBy > --

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

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

[ https://issues.apache.org/jira/browse/FLINK-34519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-34519: - Description: In the current implementation, CheckpointCoordinator#startCheckpointScheduler woul

[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] [Commented] (FLINK-34424) BoundedBlockingSubpartitionWriteReadTest#testRead10ConsumersConcurrent times out

[ https://issues.apache.org/jira/browse/FLINK-34424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819495#comment-17819495 ] Yunfeng Zhou commented on FLINK-34424: -- Hi [~mapohl]  and [~pnowojski], [~tanyuxin]

[jira] [Comment Edited] (FLINK-34424) BoundedBlockingSubpartitionWriteReadTest#testRead10ConsumersConcurrent times out

[ https://issues.apache.org/jira/browse/FLINK-34424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818436#comment-17818436 ] Yunfeng Zhou edited comment on FLINK-34424 at 2/19/24 10:16 AM: --

[jira] [Commented] (FLINK-34424) BoundedBlockingSubpartitionWriteReadTest#testRead10ConsumersConcurrent times out

[ https://issues.apache.org/jira/browse/FLINK-34424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818436#comment-17818436 ] Yunfeng Zhou commented on FLINK-34424: -- [~mapohl] [~pnowojski] I'll try to figure o

[jira] [Commented] (FLINK-34395) Release Testing Instructions: Verify FLINK-32514 Support using larger checkpointing interval when source is processing backlog

[ https://issues.apache.org/jira/browse/FLINK-34395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817575#comment-17817575 ] Yunfeng Zhou commented on FLINK-34395: -- Hi [~lincoln.86xy] [~jingge] Sorry for the

[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] [Commented] (FLINK-34169) [benchmark] CI fails during test running

[ https://issues.apache.org/jira/browse/FLINK-34169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813469#comment-17813469 ] Yunfeng Zhou commented on FLINK-34169: -- Fixed in 8dd28a2e8bf10ec278ff90c99563468e29

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

[ https://issues.apache.org/jira/browse/FLINK-32514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-32514: - Release Note: ProcessingBacklog is introduced to demonstrate whether a record should be processe

[jira] [Commented] (FLINK-34233) HybridShuffleITCase.testHybridSelectiveExchangesRestart failed due to a IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-34233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811073#comment-17811073 ] Yunfeng Zhou commented on FLINK-34233: -- Hi [~mapohl], truly this is also a bug caus

[jira] [Commented] (FLINK-34225) HybridShuffleITCase.testHybridSelectiveExchangesRestart failed due to NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-34225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810280#comment-17810280 ] Yunfeng Zhou commented on FLINK-34225: -- Hi [~mapohl] thanks for raising this bug. I

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

[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-34077: - Description: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56357&view=

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

[jira] [Commented] (FLINK-33534) PipelineOptions.PARALLELISM_OVERRIDES is not picked up from jar submission request

[ https://issues.apache.org/jira/browse/FLINK-33534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790429#comment-17790429 ] Yunfeng Zhou commented on FLINK-33534: -- Hi [~gyfora] [~mxm] [~fanrui] , I'm interes

[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] [Commented] (FLINK-32494) Cannot convert list literal to Table with PyFlink

[ https://issues.apache.org/jira/browse/FLINK-32494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738841#comment-17738841 ] Yunfeng Zhou commented on FLINK-32494: -- Hi [~hxbks2ks], could you please take a loo

[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] [Updated] (FLINK-32464) AssertionError when converting between Table and SQL with selection and type cast

[ https://issues.apache.org/jira/browse/FLINK-32464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-32464: - Description: In an attempt to convert table between Table API and SQL API using the following p

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

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

[ https://issues.apache.org/jira/browse/FLINK-31240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706673#comment-17706673 ] Yunfeng Zhou commented on FLINK-31240: -- It seems that I do not have permission to m

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

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

[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686137#comment-17686137 ] Yunfeng Zhou commented on FLINK-30959: -- Hi [~leonard] , Thanks for driving this iss

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

[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685794#comment-17685794 ] Yunfeng Zhou commented on FLINK-30959: -- cc [~twalthr] [~godfrey] Thanks for the com

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-30168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675771#comment-17675771 ] Yunfeng Zhou commented on FLINK-30168: -- Thanks for the reminding. Here are the code

[jira] [Commented] (FLINK-30191) Update py4j from 0.10.9.3 to 0.10.9.7

[ https://issues.apache.org/jira/browse/FLINK-30191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656477#comment-17656477 ] Yunfeng Zhou commented on FLINK-30191: -- Hi [~martijnvisser], would you mind my aski

[jira] [Commented] (FLINK-26029) Generalize the checkpoint protocol of OperatorCoordinator.

[ https://issues.apache.org/jira/browse/FLINK-26029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653799#comment-17653799 ] Yunfeng Zhou commented on FLINK-26029: -- According to offline discussions with Dong

[jira] [Comment Edited] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

[ https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651958#comment-17651958 ] Yunfeng Zhou edited comment on FLINK-29217 at 1/3/23 5:36 AM:

[jira] [Comment Edited] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

[ https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651958#comment-17651958 ] Yunfeng Zhou edited comment on FLINK-29217 at 1/3/23 3:11 AM:

[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] [Commented] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

[ https://issues.apache.org/jira/browse/FLINK-29217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651958#comment-17651958 ] Yunfeng Zhou commented on FLINK-29217: -- According to offline discussion with Becket

[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] [Commented] (FLINK-30168) PyFlink Deserialization Error with Object Array

[ https://issues.apache.org/jira/browse/FLINK-30168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641051#comment-17641051 ] Yunfeng Zhou commented on FLINK-30168: -- Apart from the proposed solution mentioned

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

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

[ https://issues.apache.org/jira/browse/FLINK-30142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-30142: - Priority: Minor (was: Major) > Flink ML operators lose table watermark after transform() >

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

[ https://issues.apache.org/jira/browse/FLINK-30122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637718#comment-17637718 ] Yunfeng Zhou edited comment on FLINK-30122 at 11/24/22 2:25 AM: --

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

[ https://issues.apache.org/jira/browse/FLINK-30122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637718#comment-17637718 ] Yunfeng Zhou commented on FLINK-30122: -- It has been discovered that PyFlink has a b

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

[ https://issues.apache.org/jira/browse/FLINK-30168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-30168: - Issue Type: Bug (was: Improvement) > PyFlink Deserialization Error with Object Array >

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

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

[ https://issues.apache.org/jira/browse/FLINK-30168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-30168: - Description: When it is attempted to collect object array records from a DataStream in PyFlink,

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

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

[ https://issues.apache.org/jira/browse/FLINK-30142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-30142: - Description: Given FLINK-30130 and the datastream-table conversion process usually does not prop

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-30009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-30009: - Description: The following description lies in the JavaDoc of {{OperatorCoordinator.start()}}.

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

[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] [Updated] (FLINK-29604) Add Estimator and Transformer for CountVectorizer

[ https://issues.apache.org/jira/browse/FLINK-29604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29604: - Description: Add Estimator and Transformer for CountVectorizer. Its function would be at least

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

[ https://issues.apache.org/jira/browse/FLINK-29603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29603: - Description: Add Transformer for StopWordsRemover. Its function would be at least equivalent to

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

[ https://issues.apache.org/jira/browse/FLINK-29602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29602: - Description: Add Transformer for SQLTransformer. Its function would be at least equivalent to S

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

[ https://issues.apache.org/jira/browse/FLINK-29599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29599: - Description: Add Estimator and Transformer for MinHashLSH. Its function would be at least equiv

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

[ https://issues.apache.org/jira/browse/FLINK-29601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29601: - Description: Add Estimator and Transformer for UnivariateFeatureSelector. Its function would be

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

[ https://issues.apache.org/jira/browse/FLINK-29600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29600: - Description: Add Estimator and Transformer for BucketedRandomProjectionLSH. Its function would

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

[ https://issues.apache.org/jira/browse/FLINK-29598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29598: - Description: Add Estimator and Transformer for Imputer Its function would be at least equivalen

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

[ https://issues.apache.org/jira/browse/FLINK-29598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29598: - Description: Add Estimator and Transformer for Imputer Its function would be at least equivalen

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

[ https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29595: - Description: Add the Estimator and Transformer for ChiSqSelector. Its function would be at leas

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

[ https://issues.apache.org/jira/browse/FLINK-29597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29597: - Description: Add Estimator and Transformer for QuantileDiscretizer. Its function would be at le

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

[ https://issues.apache.org/jira/browse/FLINK-29596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29596: - Description: Add Estimator and Transformer for RFormula. Its function would be at least equival

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

[ https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29595: - Description: Add the Estimator and Transformer for ChiSqSelector. Its function would be at leas

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

[ https://issues.apache.org/jira/browse/FLINK-29596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29596: - Description: Add Estimator and Transformer for RFormula. Its function would be at least equival

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

[ https://issues.apache.org/jira/browse/FLINK-29597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29597: - Description: Add Estimator and Transformer for QuantileDiscretizer. Its function would be at le

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

[ https://issues.apache.org/jira/browse/FLINK-29597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29597: - Description: Add Estimator and Transformer for QuantileDiscretizer. Its function would be at le

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

[ https://issues.apache.org/jira/browse/FLINK-29598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29598: - Description: Add Estimator and Transformer for Imputer Its function would be at least equivalen

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

[ https://issues.apache.org/jira/browse/FLINK-29596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29596: - Description: Add Estimator and Transformer for RFormula. Its function would be at least equival

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

[ https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29595: - Description: Add the Estimator and Transformer for ChiSqSelector. Its function would be at leas

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-29596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-29596: - Component/s: Library / Machine Learning > Add Estimator and Transformer for RFormula > -

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

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

  1   2   >