[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363298#comment-17363298
]
Dong Lin commented on FLINK-22085:
--
[~xintongsong] No... after spending 2+ hours over the weekend to
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363324#comment-17363324
]
Dong Lin commented on FLINK-22085:
--
[~xintongsong] Sure, please feel free to un-assign me. Thanks!
>
Dong Lin created FLINK-22915:
Summary: Extend Flink ML API to support Estimator/Transformer DAG
Key: FLINK-22915
URL: https://issues.apache.org/jira/browse/FLINK-22915
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366359#comment-17366359
]
Dong Lin commented on FLINK-22085:
--
[~gaoyunhaii] Thanks for the investigation. Previously I have
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22915:
-
Description:
The existing Flink ML library allows users to compose an Estimator/Transformer
from a
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22915:
-
Description:
The existing Flink ML API allows users to compose an Estimator/Transformer from
a
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22915:
-
Description:
Currently Flink ML API allows users to compose an Estimator/Transformer from a
pipeline
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22915:
-
Description:
The existing Flink ML library allows users to compose an Estimator/Transformer
from a
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22915:
-
Description:
The FLIP design doc can be found at
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373128#comment-17373128
]
Dong Lin commented on FLINK-22085:
--
Thanks you [~gaoyunhaii] for the explanation!
Do you plan to
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332957#comment-17332957
]
Dong Lin edited comment on FLINK-22085 at 4/27/21, 5:53 AM:
Thank you
[
https://issues.apache.org/jira/browse/FLINK-22488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333032#comment-17333032
]
Dong Lin commented on FLINK-22488:
--
[~dwysakowicz] Right, FLINK-21996 tries to address the issue where
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332957#comment-17332957
]
Dong Lin commented on FLINK-22085:
--
Thank you [~dwysakowicz] for the information.
For the first test
Dong Lin created FLINK-22488:
Summary: KafkaSourceLegacyITCase.testOneToOneSources failed due to
"OperatorEvent from an OperatorCoordinator to a task was lost"
Key: FLINK-22488
URL:
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333085#comment-17333085
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] I see. Previously the test would be fail with
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333172#comment-17333172
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] Hmm... why would the test hang in a random spot if
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330815#comment-17330815
]
Dong Lin edited comment on FLINK-22085 at 4/23/21, 2:29 PM:
[~dwysakowicz]
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330815#comment-17330815
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] After applying
Dong Lin created FLINK-21335:
Summary: READEME should use "mvn install" instead of "mvn package"
to compile Flink
Key: FLINK-21335
URL: https://issues.apache.org/jira/browse/FLINK-21335
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-21335:
-
Summary: README should use "mvn install" instead of "mvn package" to
compile Flink (was: READEME
[
https://issues.apache.org/jira/browse/FLINK-21335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281770#comment-17281770
]
Dong Lin commented on FLINK-21335:
--
I agree it is better to use "mvn package" if the goal is just to
[
https://issues.apache.org/jira/browse/FLINK-21335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281788#comment-17281788
]
Dong Lin commented on FLINK-21335:
--
Thank you [~chesnay] for the reference link. It seems that the wiki
Dong Lin created FLINK-21976:
Summary: Move Flink ML pipeline API and library code to a separate
repository named flink-ml
Key: FLINK-21976
URL: https://issues.apache.org/jira/browse/FLINK-21976
Project:
[
https://issues.apache.org/jira/browse/FLINK-21976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17308777#comment-17308777
]
Dong Lin commented on FLINK-21976:
--
+[~becket_qin] FYI
> Move Flink ML pipeline API and library code
[
https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311175#comment-17311175
]
Dong Lin commented on FLINK-20114:
--
Hi [~rmetzger], thank you for doing the test! Here is the status
[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311261#comment-17311261
]
Dong Lin edited comment on FLINK-21214 at 3/30/21, 8:18 AM:
[~dwysakowicz]
[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311261#comment-17311261
]
Dong Lin commented on FLINK-21214:
--
[~dwysakowicz] we have investigated this bug previously and the
[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311269#comment-17311269
]
Dong Lin commented on FLINK-21214:
--
Thank you Dawid for keeping track of these bugs!
>
[
https://issues.apache.org/jira/browse/FLINK-22012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22012:
-
Priority: Major (was: Blocker)
> Add nightly-build pipeline to test flink-ml repo with the latest
Dong Lin created FLINK-22012:
Summary: Add nightly-build pipeline to test flink-ml repo with the
latest flink repo snapshot
Key: FLINK-22012
URL: https://issues.apache.org/jira/browse/FLINK-22012
Dong Lin created FLINK-22013:
Summary: Add CI to run tests in Azure DevOps pipeline for every
flink-ml pull request
Key: FLINK-22013
URL: https://issues.apache.org/jira/browse/FLINK-22013
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22013:
-
Summary: Add Github Actions to flink-ml for every push and pull request
(was: Add CI to run tests in
[
https://issues.apache.org/jira/browse/FLINK-21691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed FLINK-21691.
Resolution: Duplicate
Close this JIRA since it duplicates
[
https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-21160:
-
Description:
The variable {{deserializer}} in class {{ValueDeserializerWrapper}} won't be
instantiated
[
https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-21160:
-
Description:
The variable {{deserializer}} in class {{ValueDeserializerWrapper}} won't be
instantiated
[
https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-21160:
-
Description:
The variable {{deserializer}} in class {{ValueDeserializerWrapper}} won't be
instantiated
[
https://issues.apache.org/jira/browse/FLINK-21706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300066#comment-17300066
]
Dong Lin commented on FLINK-21706:
--
I have investigated this bug. The bug is not currently reproducible
[
https://issues.apache.org/jira/browse/FLINK-21706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300066#comment-17300066
]
Dong Lin edited comment on FLINK-21706 at 3/12/21, 6:11 AM:
I have
[
https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-20379:
-
Summary: Update KafkaRecordDeserializationSchema to enable reuse of
DeserializationSchema and
[
https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289928#comment-17289928
]
Dong Lin commented on FLINK-21214:
--
Given that this test has the same error message as
[
https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291364#comment-17291364
]
Dong Lin commented on FLINK-20431:
--
According to the test history of the
[
https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291362#comment-17291362
]
Dong Lin commented on FLINK-20928:
--
According to the test history of the
[
https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291362#comment-17291362
]
Dong Lin edited comment on FLINK-20928 at 2/26/21, 3:16 AM:
According to the
[
https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288794#comment-17288794
]
Dong Lin commented on FLINK-16686:
--
Discussed with [~yunta] about this bug. This bug is hard to fix
[
https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316819#comment-17316819
]
Dong Lin commented on FLINK-16908:
--
I think this is due to the same issue as described in
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316817#comment-17316817
]
Dong Lin commented on FLINK-18634:
--
[~trohrmann] It appears that flink-tests/src/test's root logger
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316991#comment-17316991
]
Dong Lin commented on FLINK-18634:
--
Sounds good. Thank you [~trohrmann] for fixing it.
>
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1738#comment-1738
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] I have updated this JIRA with the root cause
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22085:
-
Description:
*Observations*
1) The Azure pipeline would occasionally hang without printing any test
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22085:
-
Description:
1) Observations
a) The Azure pipeline would occasionally hang without printing any test
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318958#comment-17318958
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] Sure, I will take a look.
> KafkaSourceLegacyITCase
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321044#comment-17321044
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] Sorry, I was busy with other work and didn't realize
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321105#comment-17321105
]
Dong Lin commented on FLINK-22085:
--
Sounds good. I will use my personal azure account.
I am able to
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325643#comment-17325643
]
Dong Lin commented on FLINK-22085:
--
Thanks for the information [~mapohl]. Previously I have verified
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286534#comment-17286534
]
Dong Lin commented on FLINK-18634:
--
Sounds good. I will try to upgrade Kafka dependency to 2.5.1.
>
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284445#comment-17284445
]
Dong Lin commented on FLINK-18634:
--
- According to the log [1] from Till, testScaleUpAfterScalingDown
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17284542#comment-17284542
]
Dong Lin commented on FLINK-18634:
--
There is no Kafka 2.4.2 release. And we can not simply bump up the
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287086#comment-17287086
]
Dong Lin commented on FLINK-18634:
--
Kafka 2.5.1 has dropped support for Scala 2.11. Flink will also
[
https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1732#comment-1732
]
Dong Lin commented on FLINK-22085:
--
[~dwysakowicz] Yeah I am able to reproduce the test hang once. I
[
https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400893#comment-17400893
]
Dong Lin commented on FLINK-22198:
--
I have taken a look at the test code and related logs (not
Dong Lin created FLINK-23959:
Summary: FLIP-175: Add GraphBuilder to compose
Estimator/Transformer/AlgoOperator from a DAG of stages
Key: FLINK-23959
URL: https://issues.apache.org/jira/browse/FLINK-23959
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22915:
-
Description:
The FLIP design doc can be found at
[
https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402527#comment-17402527
]
Dong Lin commented on FLINK-22198:
--
Hey [~fsk119], do you think it would be simpler to just change the
[
https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401669#comment-17401669
]
Dong Lin commented on FLINK-22198:
--
Here are my findings regarding why the timestamp of the produced
[
https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17419263#comment-17419263
]
Dong Lin commented on FLINK-20928:
--
[~dwysakowicz] I found a possible explanation for the flaky test
Dong Lin created FLINK-24398:
Summary: KafkaSourceFetcherManager should re-use an existing
SplitFetcher to commit offset if possible
Key: FLINK-24398
URL: https://issues.apache.org/jira/browse/FLINK-24398
Dong Lin created FLINK-24354:
Summary: FLIP-174: Improve the WithParam interface
Key: FLINK-24354
URL: https://issues.apache.org/jira/browse/FLINK-24354
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-23959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-23959:
-
Description:
The FLIP design doc can be found at
[
https://issues.apache.org/jira/browse/FLINK-24354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-24354:
-
Issue Type: New Feature (was: Improvement)
> FLIP-174: Improve the WithParam interface
>
[
https://issues.apache.org/jira/browse/FLINK-24557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-24557:
-
Fix Version/s: ml-2.0.0
> Support Knn in FlinkML
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-24557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-24557:
-
Issue Type: New Feature (was: Bug)
> Support Knn in FlinkML
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-25121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25121:
-
Fix Version/s: ml-2.0.0
> Support ML Python API
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-23959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-23959:
-
Issue Type: New Feature (was: Improvement)
> FLIP-175: Compose Estimator/Model/AlgoOperator from DAG
[
https://issues.apache.org/jira/browse/FLINK-22915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-22915:
-
Issue Type: New Feature (was: Improvement)
> FLIP-173: Support DAG of algorithms
>
[
https://issues.apache.org/jira/browse/FLINK-24810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-24810:
-
Issue Type: New Feature (was: Improvement)
> Add Estimator and Model for the k-means clustering
Dong Lin created FLINK-25509:
Summary: FLIP-208: Update KafkaSource to detect EOF based on
de-serialized records
Key: FLINK-25509
URL: https://issues.apache.org/jira/browse/FLINK-25509
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25509:
-
Issue Type: Improvement (was: Bug)
> FLIP-208: Update KafkaSource to detect EOF based on de-serialized
[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25509:
-
Description: Please checkout
[
https://issues.apache.org/jira/browse/FLINK-25368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465544#comment-17465544
]
Dong Lin commented on FLINK-25368:
--
Thanks for the creating the ticket to improve Flink!
I think the
[
https://issues.apache.org/jira/browse/FLINK-23959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-23959:
-
Summary: FLIP-175: Compose Estimator/Model/AlgoOperator from DAG of
Estimator/Model/AlgoOperator (was:
[
https://issues.apache.org/jira/browse/FLINK-24810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-24810:
-
Component/s: Library / Machine Learning
> Add Estimator and Model for the k-means clustering algorithm
[
https://issues.apache.org/jira/browse/FLINK-24354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-24354:
-
Component/s: Library / Machine Learning
> FLIP-174: Improve the WithParam interface
>
[
https://issues.apache.org/jira/browse/FLINK-23959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-23959:
-
Component/s: Library / Machine Learning
> FLIP-175: Add GraphBuilder to compose
[
https://issues.apache.org/jira/browse/FLINK-24810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-24810:
-
Description:
See [https://en.wikipedia.org/wiki/K-means_clustering] for the algorithm
description.
[
https://issues.apache.org/jira/browse/FLINK-24810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-24810:
-
Description:
See https://e n.wikipedia.org/wiki/K-means_clustering for the algorithm
description.
Dong Lin created FLINK-24810:
Summary: Add Estimator and Model for the k-means clustering
algorithm
Key: FLINK-24810
URL: https://issues.apache.org/jira/browse/FLINK-24810
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-25148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25148:
-
Description:
We observed the following stacktrace when running the unit test
[
https://issues.apache.org/jira/browse/FLINK-25148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25148:
-
Description:
We observed the following stacktrace when running the unit test
[
https://issues.apache.org/jira/browse/FLINK-25148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25148:
-
Description:
We observed the following stacktrace when running the unit test
[
https://issues.apache.org/jira/browse/FLINK-25148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25148:
-
Description:
We observed the following stacktrace when running the unit test
Dong Lin created FLINK-25148:
Summary: PipelinedSubpartition.resumeConsumption throws
IllegalStateException
Key: FLINK-25148
URL: https://issues.apache.org/jira/browse/FLINK-25148
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-26171:
Assignee: Huang Xingbo
> pyFlink -py options has issue with path that starts with //
>
[
https://issues.apache.org/jira/browse/FLINK-26313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-26313:
Assignee: Yunfeng Zhou
> Support Streaming KMeans in Flink ML
>
[
https://issues.apache.org/jira/browse/FLINK-26313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-26313:
-
Component/s: Library / Machine Learning
> Support Streaming KMeans in Flink ML
>
[
https://issues.apache.org/jira/browse/FLINK-26100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-26100:
-
Issue Type: Improvement (was: New Feature)
> Set up Flink ML Document Website
>
[
https://issues.apache.org/jira/browse/FLINK-26100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-26100:
-
Component/s: Documentation
> Set up Flink ML Document Website
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-26100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-26100:
-
Component/s: (was: Documentation)
> Set up Flink ML Document Website
>
[
https://issues.apache.org/jira/browse/FLINK-26100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-26100:
Assignee: Yunfeng Zhou
> Set up Flink ML Document Website
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-25552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25552:
-
Summary: Add Estimator and Transformer for MinMaxScaler (was: Support
MinMaxScaler in FlinkML)
> Add
[
https://issues.apache.org/jira/browse/FLINK-25527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated FLINK-25527:
-
Summary: Add Transformer and Estimator for StringIndexer (was: Add
StringIndexer in FlinkML)
> Add
1 - 100 of 716 matches
Mail list logo
