[jira] [Created] (FLINK-26273) Test checkpoints restore modes & formats

2022-02-20 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-26273: Summary: Test checkpoints restore modes & formats Key: FLINK-26273 URL: https://issues.apache.org/jira/browse/FLINK-26273 Project: Flink Issue Type:

[jira] [Created] (FLINK-26272) Elasticsearch7SinkITCase.testWriteJsonToElasticsearch fails with socket timeout

2022-02-20 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26272: - Summary: Elasticsearch7SinkITCase.testWriteJsonToElasticsearch fails with socket timeout Key: FLINK-26272 URL: https://issues.apache.org/jira/browse/FLINK-26272

[jira] [Created] (FLINK-26271) TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed

2022-02-20 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-26271: - Summary: TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed Key: FLINK-26271 URL: https://issues.apache.org/jira/browse/FLINK-26271 Project: Flink

[jira] [Created] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation

2022-02-20 Thread fengjk (Jira)
fengjk created FLINK-26270: -- Summary: Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation Key: FLINK-26270 URL: https://issues.apache.org/jira/browse/FLINK-26270

Re: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator

2022-02-20 Thread Yang Wang
I also lean to persist the FlinkDeployment and its status via K8s resources. Unless necessary, we should not introduce other external dependencies(e.g. mysql). It will make the k8s operator more complicated. Best, Yang Gyula Fóra 于2022年2月21日周一 02:48写道： > Hi! > > Thank you for your interest in

[jira] [Created] (FLINK-26269) Add clustering algorithm support for KMeans in ML Python API

2022-02-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26269: Summary: Add clustering algorithm support for KMeans in ML Python API Key: FLINK-26269 URL: https://issues.apache.org/jira/browse/FLINK-26269 Project: Flink

[jira] [Created] (FLINK-26268) Add classfication algorithm support for LogisticRegression, KNN and NaiveBayes in ML Python API

2022-02-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26268: Summary: Add classfication algorithm support for LogisticRegression, KNN and NaiveBayes in ML Python API Key: FLINK-26268 URL: https://issues.apache.org/jira/browse/FLINK-26268

[jira] [Created] (FLINK-26267) Add common params interface in ML Python API

2022-02-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26267: Summary: Add common params interface in ML Python API Key: FLINK-26267 URL: https://issues.apache.org/jira/browse/FLINK-26267 Project: Flink Issue Type:

[jira] [Created] (FLINK-26266) Support Vector and Matrix

2022-02-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26266: Summary: Support Vector and Matrix Key: FLINK-26266 URL: https://issues.apache.org/jira/browse/FLINK-26266 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26265) Support Java Algorithm in Python ML API

2022-02-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26265: Summary: Support Java Algorithm in Python ML API Key: FLINK-26265 URL: https://issues.apache.org/jira/browse/FLINK-26265 Project: Flink Issue Type: New

[jira] [Created] (FLINK-26264) Python Test failed on its docs building phase

2022-02-20 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-26264: -- Summary: Python Test failed on its docs building phase Key: FLINK-26264 URL: https://issues.apache.org/jira/browse/FLINK-26264 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26263) Check data size in LogisticRegression

2022-02-20 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-26263: Summary: Check data size in LogisticRegression Key: FLINK-26263 URL: https://issues.apache.org/jira/browse/FLINK-26263 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26262) Rest API to submit PyFlink job

2022-02-20 Thread Thanh Thao Huynh (Jira)
Thanh Thao Huynh created FLINK-26262: Summary: Rest API to submit PyFlink job Key: FLINK-26262 URL: https://issues.apache.org/jira/browse/FLINK-26262 Project: Flink Issue Type: New

[jira] [Created] (FLINK-26261) Reconciliation should try to start job when not already started or move to permanent error

2022-02-20 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-26261: Summary: Reconciliation should try to start job when not already started or move to permanent error Key: FLINK-26261 URL: https://issues.apache.org/jira/browse/FLINK-26261

[jira] [Created] (FLINK-26260) Support watching specific namespace for FlinkDeployments

2022-02-20 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26260: -- Summary: Support watching specific namespace for FlinkDeployments Key: FLINK-26260 URL: https://issues.apache.org/jira/browse/FLINK-26260 Project: Flink Issue

Re: [DISCUSS] Plan to externalize connectors and versioning

2022-02-20 Thread Chesnay Schepler
If we don't make a release, I think it would appear as partially externalized (since the binaries are still only created with Flink core, not from the external repository). I'm wondering you are referring to when you say "it appear[s]". Users don't know about it, and contributors can be

Re: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator

2022-02-20 Thread Gyula Fóra
Hi! Thank you for your interest in contributing to the operator. The operator persists information in the status of the FlinkDeployment resource. We should not need any additional persistence layer on top of this in the current design. Could you please give me a concrete example of what is not