[jira] [Closed] (FLINK-34149) Flink Kafka connector can't compile against 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-34149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-34149. Resolution: Fixed > Flink Kafka connector can't compile against 1.19-SNAPSHOT >

[jira] [Assigned] (FLINK-34149) Flink Kafka connector can't compile against 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-34149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-34149: Assignee: Yunfeng Zhou > Flink Kafka connector can't compile against 1.19-SNAPSHOT >

[jira] [Commented] (FLINK-34149) Flink Kafka connector can't compile against 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-34149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808624#comment-17808624 ] Dong Lin commented on FLINK-34149: -- Merged to master branch b309ceb8de005fd65d979ffce928d08606f36e89 >

[jira] [Commented] (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:comment-tabpanel=17808188#comment-17808188 ] Dong Lin commented on FLINK-32514: -- Somehow I thought Flink 1.19 has already been released (by

[jira] [Commented] (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:comment-tabpanel=17808171#comment-17808171 ] Dong Lin commented on FLINK-32514: -- [~martijnvisser] Sorry for the issue. It appears that we should

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798080#comment-17798080 ] Dong Lin commented on FLINK-25509: -- [~martijnvisser] Cool. I totally agree with your suggestion. >

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798047#comment-17798047 ] Dong Lin commented on FLINK-25509: -- [~martijnvisser] Just to make sure that I understand you correctly,

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798026#comment-17798026 ] Dong Lin commented on FLINK-25509: -- [~ruanhang1993] I think we need to update flink-kafka-connector's

[jira] [Commented] (FLINK-33316) Avoid unnecessary heavy getStreamOperatorFactory

[ https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1552#comment-1552 ] Dong Lin commented on FLINK-33316: -- [~fanrui] I think it makes sense to cherry-pick this to the next

[jira] [Commented] (FLINK-33316) Avoid unnecessary heavy getStreamOperatorFactory

[ https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1250#comment-1250 ] Dong Lin commented on FLINK-33316: -- Merged to the apache/flink master branch at

[jira] [Closed] (FLINK-33316) Avoid unnecessary heavy getStreamOperatorFactory

[ https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-33316. Resolution: Fixed > Avoid unnecessary heavy getStreamOperatorFactory >

[jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772212#comment-17772212 ] Dong Lin commented on FLINK-33186: -- cc [~xtsong]  >

[jira] [Assigned] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-33186: Assignee: Jiang Xin > CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished

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

[ https://issues.apache.org/jira/browse/FLINK-33118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-33118. Resolution: Fixed > Remove the PythonBridgeUtils > > > Key:

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

[ https://issues.apache.org/jira/browse/FLINK-33118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-33118: Assignee: Jiang Xin > Remove the PythonBridgeUtils > > >

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

[ https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32704. Resolution: Fixed > Supports spilling to disk when feedback channel memory buffer is full >

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

[ https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764635#comment-17764635 ] Dong Lin commented on FLINK-32704: -- Merged to apache/flink-ml master branch

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

[ https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-32704: Assignee: Jiang Xin > Supports spilling to disk when feedback channel memory buffer is full >

[jira] [Closed] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32996. Resolution: Fixed > CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished > fails on

[jira] [Updated] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-32996: - Fix Version/s: 1.18.0 > CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished >

[jira] [Commented] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761270#comment-17761270 ] Dong Lin commented on FLINK-32996: -- Merged to apache/flink master branch

[jira] [Assigned] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-32996: Assignee: Jiang Xin > CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished

[jira] [Updated] (FLINK-32945) NullPointerException when executing TopSpeedWindowing example with checkpointing enabled

[ https://issues.apache.org/jira/browse/FLINK-32945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-32945: - Fix Version/s: 1.18.0 > NullPointerException when executing TopSpeedWindowing example with >

[jira] [Closed] (FLINK-32945) NullPointerException when executing TopSpeedWindowing example with checkpointing enabled

[ https://issues.apache.org/jira/browse/FLINK-32945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32945. Resolution: Fixed > NullPointerException when executing TopSpeedWindowing example with > checkpointing

[jira] [Commented] (FLINK-32945) NullPointerException when executing TopSpeedWindowing example with checkpointing enabled

[ https://issues.apache.org/jira/browse/FLINK-32945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760317#comment-17760317 ] Dong Lin commented on FLINK-32945: -- Merged to apache/flink master branch

[jira] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996 ] Dong Lin deleted comment on FLINK-32996: -- was (Author: lindong): [~Sergey Nuyanzin] Given that it seems to be the same issue as FLINK-32907, can we close it as a duplicate? >

[jira] [Commented] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760315#comment-17760315 ] Dong Lin commented on FLINK-32996: -- [~Sergey Nuyanzin] Given that it seems to be the same issue as

[jira] [Closed] (FLINK-32907) CheckpointAfterAllTasksFinishedITCase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-32907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32907. Resolution: Fixed > CheckpointAfterAllTasksFinishedITCase hangs on AZP >

[jira] [Assigned] (FLINK-32907) CheckpointAfterAllTasksFinishedITCase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-32907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-32907: Assignee: Jiang Xin > CheckpointAfterAllTasksFinishedITCase hangs on AZP >

[jira] [Commented] (FLINK-32907) CheckpointAfterAllTasksFinishedITCase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-32907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759877#comment-17759877 ] Dong Lin commented on FLINK-32907: -- Merged into apache/flink master branch

[jira] [Updated] (FLINK-32907) CheckpointAfterAllTasksFinishedITCase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-32907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-32907: - Fix Version/s: 1.18.0 > CheckpointAfterAllTasksFinishedITCase hangs on AZP >

[jira] [Closed] (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 ] Dong Lin closed FLINK-32514. Resolution: Fixed > FLIP-309: Support using larger checkpointing interval when source is > processing

[jira] [Commented] (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:comment-tabpanel=17758438#comment-17758438 ] Dong Lin commented on FLINK-32514: -- Merged to apache/flink master branch

[jira] [Assigned] (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 ] Dong Lin reassigned FLINK-32514: Assignee: Yunfeng Zhou > FLIP-309: Support using larger checkpointing interval when source is >

[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 ] Dong Lin updated FLINK-32514: - Fix Version/s: 1.19.0 > FLIP-309: Support using larger checkpointing interval when source is >

[jira] [Commented] (FLINK-32663) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750156#comment-17750156 ] Dong Lin commented on FLINK-32663: -- [~mapohl] Thanks for the reminder. Will do it in the future :) >

[jira] [Closed] (FLINK-32663) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32663. Resolution: Fixed > RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails on > AZP

[jira] [Commented] (FLINK-32663) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750102#comment-17750102 ] Dong Lin commented on FLINK-32663: -- Merged to apache/flink master branch

[jira] [Commented] (FLINK-32663) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750073#comment-17750073 ] Dong Lin commented on FLINK-32663: -- [~fanrui] Thanks for the investigation! FLINK-27386 is expected to

[jira] [Commented] (FLINK-32663) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749719#comment-17749719 ] Dong Lin commented on FLINK-32663: -- Hi [~fanrui], FLINK-28386 will let Flink runtime trigger a

[jira] [Updated] (FLINK-28386) Trigger an immediate checkpoint after all tasks has reached end-of-data

[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-28386: - Description: Currently for bounded job in streaming mode, by default it will wait for one more

[jira] [Updated] (FLINK-28386) Trigger an immediate checkpoint after all tasks has reached end-of-data

[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-28386: - Summary: Trigger an immediate checkpoint after all tasks has reached end-of-data (was: Trigger an

[jira] [Updated] (FLINK-28386) Trigger an immediate checkpoint after all tasks has received end-of-data

[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-28386: - Description: Currently for bounded job in streaming mode, by default it will wait for one more

[jira] [Updated] (FLINK-28386) Trigger an immediate checkpoint after all tasks has received end-of-data

[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-28386: - Summary: Trigger an immediate checkpoint after all tasks has received end-of-data (was: Trigger an

[jira] [Updated] (FLINK-28386) Trigger an immediate checkpoint after all tasks finished

[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-28386: - Summary: Trigger an immediate checkpoint after all tasks finished (was: Trigger an immediate

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746860#comment-17746860 ] Dong Lin commented on FLINK-25509: -- [~martijnvisser] This Jira is open because we are still waiting for

[jira] [Resolved] (FLINK-32545) Improves the performance by optimizing row operations

[ https://issues.apache.org/jira/browse/FLINK-32545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved FLINK-32545. -- Resolution: Fixed > Improves the performance by optimizing row operations >

[jira] [Assigned] (FLINK-32545) Improves the performance by optimizing row operations

[ https://issues.apache.org/jira/browse/FLINK-32545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-32545: Assignee: Jiang Xin > Improves the performance by optimizing row operations >

[jira] [Commented] (FLINK-32545) Improves the performance by optimizing row operations

[ https://issues.apache.org/jira/browse/FLINK-32545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744069#comment-17744069 ] Dong Lin commented on FLINK-32545: -- Merged to apache/flink-ml master branch

[jira] [Created] (FLINK-32594) Use blocking ResultPartitionType if operator only outputs records on EOF (FLIP-331)

Dong Lin created FLINK-32594: Summary: Use blocking ResultPartitionType if operator only outputs records on EOF (FLIP-331) Key: FLINK-32594 URL: https://issues.apache.org/jira/browse/FLINK-32594 Project:

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

[ https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17743010#comment-17743010 ] Dong Lin commented on FLINK-32335: -- Merged to apache/flink-ml master branch

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

[ https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved FLINK-32335. -- Resolution: Fixed > Fix the Flink ML unittest failure > - > >

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

[ https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-32335: Assignee: Jiang Xin > Fix the Flink ML unittest failure > - > >

[jira] [Commented] (FLINK-28386) Trigger an immediate checkpoint after all sources finished

[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739931#comment-17739931 ] Dong Lin commented on FLINK-28386: -- Merged to the apache/flink master branch

[jira] [Closed] (FLINK-28386) Trigger an immediate checkpoint after all sources finished

[ https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-28386. Resolution: Fixed > Trigger an immediate checkpoint after all sources finished >

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

[ https://issues.apache.org/jira/browse/FLINK-31909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-31909: - Fix Version/s: (was: ml-2.3.0) > Using BroadcastUtils#withBroadcast in iteration perround mode got

[jira] [Updated] (FLINK-31753) Support DataStream CoGroup in stream Mode with similar performance as DataSet CoGroup

[ https://issues.apache.org/jira/browse/FLINK-31753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-31753: - Issue Type: Improvement (was: Bug) > Support DataStream CoGroup in stream Mode with similar

[jira] [Assigned] (FLINK-28706) FLIP-248: Introduce dynamic partition pruning

[ https://issues.apache.org/jira/browse/FLINK-28706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-28706: Assignee: godfrey he > FLIP-248: Introduce dynamic partition pruning >

[jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737424#comment-17737424 ] Dong Lin commented on FLINK-19830: -- Hi [~rmetzger] [~jark] , FYI, FLIP-326

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

[ https://issues.apache.org/jira/browse/FLINK-31901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-31901: - Fix Version/s: ml-2.4.0 (was: ml-2.3.0) > AbstractBroadcastWrapperOperator

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

[ https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-32335: - Fix Version/s: ml-2.4.0 (was: ml-2.3.0) > Fix the Flink ML unittest failure >

[jira] [Updated] (FLINK-31948) Supports triggering CI manually

[ https://issues.apache.org/jira/browse/FLINK-31948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-31948: - Fix Version/s: ml-2.4.0 (was: ml-2.3.0) > Supports triggering CI manually >

[jira] [Created] (FLINK-32360) Optimize DataStream#coGroup in stream mode when results are emitted at end of input

Dong Lin created FLINK-32360: Summary: Optimize DataStream#coGroup in stream mode when results are emitted at end of input Key: FLINK-32360 URL: https://issues.apache.org/jira/browse/FLINK-32360 Project:

[jira] [Closed] (FLINK-32285) Support multiple Flink versions in each Flink ML Java library release

[ https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32285. Resolution: Fixed > Support multiple Flink versions in each Flink ML Java library release >

[jira] [Updated] (FLINK-32285) Support multiple Flink versions in each Flink ML Java library release

[ https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-32285: - Fix Version/s: ml-2.3.0 > Support multiple Flink versions in each Flink ML Java library release >

[jira] [Commented] (FLINK-32285) Support multiple Flink versions in each Flink ML Java library release

[ https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731136#comment-17731136 ] Dong Lin commented on FLINK-32285: -- Merged to apache/flink-ml master branch

[jira] [Assigned] (FLINK-32285) Support multiple Flink versions in each Flink ML Java library release

[ https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-32285: Assignee: Jiang Xin > Support multiple Flink versions in each Flink ML Java library release >

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

[ https://issues.apache.org/jira/browse/FLINK-32292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32292. Resolution: Fixed > TableUtils.getRowTypeInfo fails to get type information of Tuple >

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

[ https://issues.apache.org/jira/browse/FLINK-32292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17730784#comment-17730784 ] Dong Lin commented on FLINK-32292: -- Merged to apache/flink-ml master branch

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

[ https://issues.apache.org/jira/browse/FLINK-32292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-32292: Assignee: Zhipeng Zhang > TableUtils.getRowTypeInfo fails to get type information of Tuple >

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729166#comment-17729166 ] Dong Lin commented on FLINK-26803: -- [~fanrui] I see. Thanks for the information. The API change

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729069#comment-17729069 ] Dong Lin commented on FLINK-26803: -- FLIP-306 seems to be relate to this JIRA. But the newly added

[jira] [Comment Edited] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729067#comment-17729067 ] Dong Lin edited comment on FLINK-26803 at 6/4/23 2:02 PM: -- The PR of this JIRA

[jira] [Commented] (FLINK-26803) Merge small ChannelState file for Unaligned Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17729067#comment-17729067 ] Dong Lin commented on FLINK-26803: -- The PR of this JIRA introduced a new public evolving API

[jira] [Resolved] (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:all-tabpanel ] Dong Lin resolved FLINK-31240. -- Resolution: Fixed > Reduce the overhead of conversion between DataStream and Table >

[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=17726219#comment-17726219 ] Dong Lin commented on FLINK-31240: -- Merged to master branch 6b6df3db466d6a030d5a38ec786ac3297cb41c38.

[jira] [Updated] (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:all-tabpanel ] Dong Lin updated FLINK-31240: - Fix Version/s: 1.18.0 > Reduce the overhead of conversion between DataStream and Table >

[jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files

[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-2186: Component/s: (was: Library / Machine Learning) > Rework CSV import to support very wide files >

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

[ https://issues.apache.org/jira/browse/FLINK-31899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-31899. Resolution: Fixed > Upgrade Flink version of Flink ML to 1.17.0 >

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

[ https://issues.apache.org/jira/browse/FLINK-31899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-31899: Assignee: Jiang Xin > Upgrade Flink version of Flink ML to 1.17.0 >

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

[ https://issues.apache.org/jira/browse/FLINK-31899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717646#comment-17717646 ] Dong Lin commented on FLINK-31899: -- Merged to apache/flink-ml master branch

[jira] [Commented] (FLINK-31887) Upgrade Flink version of Flink ML to 1.16.1

[ https://issues.apache.org/jira/browse/FLINK-31887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716099#comment-17716099 ] Dong Lin commented on FLINK-31887: -- Merged to apache/flink-ml master branch

[jira] [Closed] (FLINK-31887) Upgrade Flink version of Flink ML to 1.16.1

[ https://issues.apache.org/jira/browse/FLINK-31887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-31887. Resolution: Fixed > Upgrade Flink version of Flink ML to 1.16.1 >

[jira] [Assigned] (FLINK-31887) Upgrade Flink version of Flink ML to 1.16.1

[ https://issues.apache.org/jira/browse/FLINK-31887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-31887: Assignee: Jiang Xin > Upgrade Flink version of Flink ML to 1.16.1 >

[jira] [Commented] (FLINK-31752) SourceOperatorStreamTask increments numRecordsOut twice

[ https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715581#comment-17715581 ] Dong Lin commented on FLINK-31752: -- Merged to apache/flink release-1.17 branch

[jira] [Commented] (FLINK-31752) SourceOperatorStreamTask increments numRecordsOut twice

[ https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715387#comment-17715387 ] Dong Lin commented on FLINK-31752: -- Merged to apache/flink master branch

[jira] [Closed] (FLINK-31752) SourceOperatorStreamTask increments numRecordsOut twice

[ https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-31752. Resolution: Fixed > SourceOperatorStreamTask increments numRecordsOut twice >

[jira] [Resolved] (FLINK-31173) Fix several bugs in flink-ml-iteration module

[ https://issues.apache.org/jira/browse/FLINK-31173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved FLINK-31173. -- Resolution: Fixed > Fix several bugs in flink-ml-iteration module >

[jira] [Commented] (FLINK-31173) Fix several bugs in flink-ml-iteration module

[ https://issues.apache.org/jira/browse/FLINK-31173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714490#comment-17714490 ] Dong Lin commented on FLINK-31173: -- Merged to apache/flink-ml master branch: -

[jira] [Updated] (FLINK-31173) Fix several bugs in flink-ml-iteration module

[ https://issues.apache.org/jira/browse/FLINK-31173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-31173: - Fix Version/s: ml-2.3.0 > Fix several bugs in flink-ml-iteration module >

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

[ https://issues.apache.org/jira/browse/FLINK-31160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-31160: - Affects Version/s: (was: ml-2.0.0) (was: ml-2.1.0) > Support

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

[ https://issues.apache.org/jira/browse/FLINK-31160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713992#comment-17713992 ] Dong Lin commented on FLINK-31160: -- Merged to apache/flink-ml master branch

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

[ https://issues.apache.org/jira/browse/FLINK-31160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-31160. Resolution: Fixed > Support join/cogroup in BroadcastUtils.withBroadcastStream >

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

[ https://issues.apache.org/jira/browse/FLINK-31276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-31276. Resolution: Cannot Reproduce > VectorIndexerTest#testFitAndPredictWithHandleInvalid fails >

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

[ https://issues.apache.org/jira/browse/FLINK-30671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713849#comment-17713849 ] Dong Lin commented on FLINK-30671: -- Hi [~kamalesh0420], sorry for late reply. I guess [~zhangzp] did

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

[ https://issues.apache.org/jira/browse/FLINK-30671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-30671: Assignee: Kamalesh Palanisamy > Add AlgoOperator for ClusteringEvaluator >

[jira] [Closed] (FLINK-29318) Add Transformer for PolynomialExpansion

[ https://issues.apache.org/jira/browse/FLINK-29318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-29318. Resolution: Fixed > Add Transformer for PolynomialExpansion > --- > >

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

[ https://issues.apache.org/jira/browse/FLINK-28224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-28224: - Affects Version/s: (was: ml-2.1.0) > Add document for algorithms and features in Flink ML 2.1 >

[jira] [Updated] (FLINK-29318) Add Transformer for PolynomialExpansion

[ https://issues.apache.org/jira/browse/FLINK-29318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29318: - Fix Version/s: ml-2.2.0 > Add Transformer for PolynomialExpansion >

[jira] [Commented] (FLINK-29318) Add Transformer for PolynomialExpansion

[ https://issues.apache.org/jira/browse/FLINK-29318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17713848#comment-17713848 ] Dong Lin commented on FLINK-29318: -- Merged to apache/flink-ml master branch

  1   2   3   4   5   6   7   8   >