[
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
> --
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-34149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808624#comment-17808624
]
Dong Lin commented on FLINK-34149:
--
Merged to master branch b309ceb8de005fd65d979ffce92
[
https://issues.apache.org/jira/browse/FLINK-32514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808188#comment-17808188
]
Dong Lin commented on FLINK-32514:
--
Somehow I thought Flink 1.19 has already been relea
[
https://issues.apache.org/jira/browse/FLINK-32514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808171#comment-17808171
]
Dong Lin commented on FLINK-32514:
--
[~martijnvisser] Sorry for the issue. It appears th
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798080#comment-17798080
]
Dong Lin commented on FLINK-25509:
--
[~martijnvisser] Cool. I totally agree with your su
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798047#comment-17798047
]
Dong Lin commented on FLINK-25509:
--
[~martijnvisser] Just to make sure that I understan
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798026#comment-17798026
]
Dong Lin commented on FLINK-25509:
--
[~ruanhang1993] I think we need to update flink-kaf
[
https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1552#comment-1552
]
Dong Lin commented on FLINK-33316:
--
[~fanrui] I think it makes sense to cherry-pick thi
[
https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1250#comment-1250
]
Dong Lin commented on FLINK-33316:
--
Merged to the apache/flink master branch at
a2681f
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772212#comment-17772212
]
Dong Lin commented on FLINK-33186:
--
cc [~xtsong]
> CheckpointAfterAllTasksFinishedIT
[
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
>
[
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: F
[
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
>
>
>
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-32704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764635#comment-17764635
]
Dong Lin commented on FLINK-32704:
--
Merged to apache/flink-ml master branch 865404910ca
[
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
> ---
[
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
[
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
> fai
[
https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761270#comment-17761270
]
Dong Lin commented on FLINK-32996:
--
Merged to apache/flink master branch 6608d873db5fd9
[
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
[
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
> checkpoint
[
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 en
[
https://issues.apache.org/jira/browse/FLINK-32945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760317#comment-17760317
]
Dong Lin commented on FLINK-32945:
--
Merged to apache/flink master branch 6c9bb3716a3a92
[ 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?
> CheckpointAfterA
[
https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760315#comment-17760315
]
Dong Lin commented on FLINK-32996:
--
[~Sergey Nuyanzin] Given that it seems to be the sa
[
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
> -
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-32907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759877#comment-17759877
]
Dong Lin commented on FLINK-32907:
--
Merged into apache/flink master branch fbcf6bffc870
[
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
> ---
[
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 bac
[
https://issues.apache.org/jira/browse/FLINK-32514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758438#comment-17758438
]
Dong Lin commented on FLINK-32514:
--
Merged to apache/flink master branch 615e824195d236
[
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
>
[
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
> processi
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750156#comment-17750156
]
Dong Lin commented on FLINK-32663:
--
[~mapohl] Thanks for the reminder. Will do it in th
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750102#comment-17750102
]
Dong Lin commented on FLINK-32663:
--
Merged to apache/flink master branch 7d07ec270cc02a
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750073#comment-17750073
]
Dong Lin commented on FLINK-32663:
--
[~fanrui] Thanks for the investigation!
FLINK-2738
[
https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749719#comment-17749719
]
Dong Lin commented on FLINK-32663:
--
Hi [~fanrui], FLINK-28386 will let Flink runtime tr
[
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 checkpoin
[
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 immed
[
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 checkpoin
[
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 imme
[
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 checkpoint
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746860#comment-17746860
]
Dong Lin commented on FLINK-25509:
--
[~martijnvisser] This Jira is open because we are s
[
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
> --
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-32545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744069#comment-17744069
]
Dong Lin commented on FLINK-32545:
--
Merged to apache/flink-ml master branch ba327b08187
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:
[
https://issues.apache.org/jira/browse/FLINK-32335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743010#comment-17743010
]
Dong Lin commented on FLINK-32335:
--
Merged to apache/flink-ml master branch 892fb4714c6
[
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
> -
>
>
[
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
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17739931#comment-17739931
]
Dong Lin commented on FLINK-28386:
--
Merged to the apache/flink master branch
c6f443c92
[
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
> -
[
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 s
[
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 performance
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737424#comment-17737424
]
Dong Lin commented on FLINK-19830:
--
Hi [~rmetzger] [~jark] , FYI, FLIP-326
[https://cw
[
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 should
[
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
> ---
[
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
> -
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:
[
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
> --
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-32285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17731136#comment-17731136
]
Dong Lin commented on FLINK-32285:
--
Merged to apache/flink-ml master branch
d38ce365e5
[
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
> ---
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-32292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730784#comment-17730784
]
Dong Lin commented on FLINK-32292:
--
Merged to apache/flink-ml master branch 0b6b7f70e45
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729166#comment-17729166
]
Dong Lin commented on FLINK-26803:
--
[~fanrui] I see. Thanks for the information. The AP
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729069#comment-17729069
]
Dong Lin commented on FLINK-26803:
--
FLIP-306 seems to be relate to this JIRA. But the n
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729067#comment-17729067
]
Dong Lin edited comment on FLINK-26803 at 6/4/23 2:02 PM:
--
The
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17729067#comment-17729067
]
Dong Lin commented on FLINK-26803:
--
The PR of this JIRA introduced a new public evolvin
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-31240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726219#comment-17726219
]
Dong Lin commented on FLINK-31240:
--
Merged to master branch 6b6df3db466d6a030d5a38ec786
[
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
> ---
[
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
> ---
[
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
>
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-31899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717646#comment-17717646
]
Dong Lin commented on FLINK-31899:
--
Merged to apache/flink-ml master branch a5b7b493e1d
[
https://issues.apache.org/jira/browse/FLINK-31887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17716099#comment-17716099
]
Dong Lin commented on FLINK-31887:
--
Merged to apache/flink-ml master branch
5b193deedf
[
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
>
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715581#comment-17715581
]
Dong Lin commented on FLINK-31752:
--
Merged to apache/flink release-1.17 branch
be13d05
[
https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715387#comment-17715387
]
Dong Lin commented on FLINK-31752:
--
Merged to apache/flink master branch 26bd5fe390e638
[
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
>
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-31173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714490#comment-17714490
]
Dong Lin commented on FLINK-31173:
--
Merged to apache/flink-ml master branch:
- 92ecb0e5
[
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
> --
[
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 join/cogroup
[
https://issues.apache.org/jira/browse/FLINK-31160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713992#comment-17713992
]
Dong Lin commented on FLINK-31160:
--
Merged to apache/flink-ml master branch
e843b300b4
[
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
> -
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-30671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713849#comment-17713849
]
Dong Lin commented on FLINK-30671:
--
Hi [~kamalesh0420], sorry for late reply. I guess [
[
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
> --
[
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
> ---
>
>
[
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
>
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-29318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17713848#comment-17713848
]
Dong Lin commented on FLINK-29318:
--
Merged to apache/flink-ml master branch 4a6ecdee6cd
1 - 100 of 716 matches
Mail list logo
