[jira] [Created] (FLINK-27082) Disable tests relying on non-writable directories

2022-04-06 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27082: Summary: Disable tests relying on non-writable directories Key: FLINK-27082 URL: https://issues.apache.org/jira/browse/FLINK-27082 Project: Flink Iss

[jira] [Created] (FLINK-27083) SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed on azure

2022-04-06 Thread Yun Gao (Jira)
Yun Gao created FLINK-27083: --- Summary: SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed on azure Key: FLINK-27083 URL: https://issues.apache.org/jira/browse/FLINK-27083 Project: Fli

[jira] [Created] (FLINK-27084) Perround mode recreating operator fails

2022-04-06 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-27084: Summary: Perround mode recreating operator fails Key: FLINK-27084 URL: https://issues.apache.org/jira/browse/FLINK-27084 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27085) Introduce snapshot.num-retained.min option

2022-04-06 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-27085: --- Summary: Introduce snapshot.num-retained.min option Key: FLINK-27085 URL: https://issues.apache.org/jira/browse/FLINK-27085 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27086) Add a QA about how to handle exception when use hive parser in hive dialect document

2022-04-06 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-27086: -- Summary: Add a QA about how to handle exception when use hive parser in hive dialect document Key: FLINK-27086 URL: https://issues.apache.org/jira/browse/FLINK-27086 Proj

[jira] [Created] (FLINK-27087) Configuration "taskmanager.network.detailed-metrics" in metrics document was mistaken as "taskmanager.net.detailed-metrics"

2022-04-06 Thread Smile (Jira)
Smile created FLINK-27087: - Summary: Configuration "taskmanager.network.detailed-metrics" in metrics document was mistaken as "taskmanager.net.detailed-metrics" Key: FLINK-27087 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (FLINK-27088) The example of using StringDeserializer for deserializing Kafka message value as string has an error

2022-04-06 Thread Penguin (Jira)
Penguin created FLINK-27088: --- Summary: The example of using StringDeserializer for deserializing Kafka message value as string has an error Key: FLINK-27088 URL: https://issues.apache.org/jira/browse/FLINK-27088

[jira] [Created] (FLINK-27089) Calling TRY_CAST with an invalid value throws IndexOutOfBounds Exception.

2022-04-06 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-27089: --- Summary: Calling TRY_CAST with an invalid value throws IndexOutOfBounds Exception. Key: FLINK-27089 URL: https://issues.apache.org/jira/browse/FLINK-27089 Project: Flin

[jira] [Created] (FLINK-27090) Add Estimator and Transformer for FTRL

2022-04-06 Thread Dong Lin (Jira)
Dong Lin created FLINK-27090: Summary: Add Estimator and Transformer for FTRL Key: FLINK-27090 URL: https://issues.apache.org/jira/browse/FLINK-27090 Project: Flink Issue Type: Bug Re

[jira] [Created] (FLINK-27091) Add Estimator and Transformer for SVM

2022-04-06 Thread Dong Lin (Jira)
Dong Lin created FLINK-27091: Summary: Add Estimator and Transformer for SVM Key: FLINK-27091 URL: https://issues.apache.org/jira/browse/FLINK-27091 Project: Flink Issue Type: Bug Compo

[jira] [Created] (FLINK-27092) Add Estimator and Transformer for Bucketizer

2022-04-06 Thread Dong Lin (Jira)
Dong Lin created FLINK-27092: Summary: Add Estimator and Transformer for Bucketizer Key: FLINK-27092 URL: https://issues.apache.org/jira/browse/FLINK-27092 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-27093) Add Estimator and Transformer for LinearReg

2022-04-06 Thread Dong Lin (Jira)
Dong Lin created FLINK-27093: Summary: Add Estimator and Transformer for LinearReg Key: FLINK-27093 URL: https://issues.apache.org/jira/browse/FLINK-27093 Project: Flink Issue Type: New Feature

Re: Creating flink-kubernetes-operator project on Dockerhub

2022-04-06 Thread Xintong Song
I think creating an official image is not necessary. Per the docker hub statement [1], "Docker Official Images are an intellectual property of Docker". So technically it's not part of the Apache Flink release, and anyone who wants can open a PR to create such an image. Thank you~ Xintong Song

[jira] [Created] (FLINK-27094) Use Boring Cyborg to link issues back to Jira

2022-04-06 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-27094: -- Summary: Use Boring Cyborg to link issues back to Jira Key: FLINK-27094 URL: https://issues.apache.org/jira/browse/FLINK-27094 Project: Flink Issue Type:

[jira] [Created] (FLINK-27095) Allow FlinkDeployment Mode Switching

2022-04-06 Thread Usamah Jassat (Jira)
Usamah Jassat created FLINK-27095: - Summary: Allow FlinkDeployment Mode Switching Key: FLINK-27095 URL: https://issues.apache.org/jira/browse/FLINK-27095 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-27096) Benchmark all algorithms included in Flink ML 2.1 release and achieve performance parity with Spark

2022-04-06 Thread Dong Lin (Jira)
Dong Lin created FLINK-27096: Summary: Benchmark all algorithms included in Flink ML 2.1 release and achieve performance parity with Spark Key: FLINK-27096 URL: https://issues.apache.org/jira/browse/FLINK-27096

Re: Wrong format when passing arguments with space

2022-04-06 Thread huweihua
HI, Kevin I have not reproduced this problem. What is the impact of this problem? Can't get this parameter correctly in user main method? Could you provide a screenshot of the JobManager configuration on the UI > 2022年4月2日 上午10:23,Kevin Lee 写道: > > It's a typo > > I run this demo on yarn cl

[jira] [Created] (FLINK-27097) Document custom validator implementations

2022-04-06 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-27097: -- Summary: Document custom validator implementations Key: FLINK-27097 URL: https://issues.apache.org/jira/browse/FLINK-27097 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-27098) The session job controller should create FlinkDeployment informer event source with namespace definition

2022-04-06 Thread Xin Hao (Jira)
Xin Hao created FLINK-27098: --- Summary: The session job controller should create FlinkDeployment informer event source with namespace definition Key: FLINK-27098 URL: https://issues.apache.org/jira/browse/FLINK-27098

[jira] [Created] (FLINK-27099) RestClient fills /tmp directory

2022-04-06 Thread Mexicapita (Jira)
Mexicapita created FLINK-27099: -- Summary: RestClient fills /tmp directory Key: FLINK-27099 URL: https://issues.apache.org/jira/browse/FLINK-27099 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-27100) Support parquet format in FileStore

2022-04-06 Thread Yubin Li (Jira)
Yubin Li created FLINK-27100: Summary: Support parquet format in FileStore Key: FLINK-27100 URL: https://issues.apache.org/jira/browse/FLINK-27100 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-04-06 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-27101: -- Summary: Periodically break the chain of incremental checkpoint Key: FLINK-27101 URL: https://issues.apache.org/jira/browse/FLINK-27101 Project: Flink Is

[jira] [Created] (FLINK-27102) Add BinaryClassificationEvaluator

2022-04-06 Thread Dong Lin (Jira)
Dong Lin created FLINK-27102: Summary: Add BinaryClassificationEvaluator Key: FLINK-27102 URL: https://issues.apache.org/jira/browse/FLINK-27102 Project: Flink Issue Type: New Feature C

[jira] [Created] (FLINK-27103) Don't store redundant primary key fields

2022-04-06 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27103: Summary: Don't store redundant primary key fields Key: FLINK-27103 URL: https://issues.apache.org/jira/browse/FLINK-27103 Project: Flink Issue Type: Sub-task

Re: pyflink on Python 3.9 dev guide

2022-04-06 Thread Xingbo Huang
Hi Luan, Your error is because the version of the Python interpreter used by your client and the cluster side is inconsistent. The default protocol version used by pickle before python 3.8 is 4, and after python 3.8 it is 5. If the two version do not match, an error will be reported as shown in yo

[jira] [Created] (FLINK-27104) ClassNotFound when submit jobs to session cluster with external jars

2022-04-06 Thread Sitan Pang (Jira)
Sitan Pang created FLINK-27104: -- Summary: ClassNotFound when submit jobs to session cluster with external jars Key: FLINK-27104 URL: https://issues.apache.org/jira/browse/FLINK-27104 Project: Flink

[jira] [Created] (FLINK-27105) wrong metric type

2022-04-06 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-27105: --- Summary: wrong metric type Key: FLINK-27105 URL: https://issues.apache.org/jira/browse/FLINK-27105 Project: Flink Issue Type: Bug Reporter: Feifan

[jira] [Created] (FLINK-27106) Flink command line support submit one job with multi jars

2022-04-06 Thread FanJia (Jira)
FanJia created FLINK-27106: -- Summary: Flink command line support submit one job with multi jars Key: FLINK-27106 URL: https://issues.apache.org/jira/browse/FLINK-27106 Project: Flink Issue Type: New

[jira] [Created] (FLINK-27107) Typo in Task

2022-04-06 Thread dizhou cao (Jira)
dizhou cao created FLINK-27107: -- Summary: Typo in Task Key: FLINK-27107 URL: https://issues.apache.org/jira/browse/FLINK-27107 Project: Flink Issue Type: Improvement Components: Runtim