[ANNOUNCE] Apache Flink 1.14.5 released

2022-06-21 Thread Xingbo Huang
The Apache Flink community is very happy to announce the release of Apache Flink 1.14.5, which is the fourth bugfix release for the Apache Flink 1.14 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

[jira] [Created] (FLINK-28191) 【flink-runtime】Achieve metrics summary and unified active reporting

2022-06-21 Thread fengjk (Jira)
fengjk created FLINK-28191: -- Summary: 【flink-runtime】Achieve metrics summary and unified active reporting Key: FLINK-28191 URL: https://issues.apache.org/jira/browse/FLINK-28191 Project: Flink

[jira] [Created] (FLINK-28190) NullPointerException is thrown if the intermediate result of nesting UDFs is used

2022-06-21 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-28190: --- Summary: NullPointerException is thrown if the intermediate result of nesting UDFs is used Key: FLINK-28190 URL: https://issues.apache.org/jira/browse/FLINK-28190

Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric

2022-06-21 Thread Jingsong Li
Thanks Qingsheng and all. I like this design. Some comments: 1. LookupCache implements Serializable? 2. Minor: After FLIP-234 [1], there should be many connectors that implement both PartialCachingLookupProvider and PartialCachingAsyncLookupProvider. Can we extract a common interface for

Re: [DISCUSS] Flink Kubernetes Operator release cadence proposal

2022-06-21 Thread Yang Wang
+1 for 2 month release cycles. Since we have promised the backward compatibility for CRD, I think it is also reasonable for us to maintain the latest two minor versions with patch releases. Given that we only have 5~6 weeks for feature development, maybe we need to confirm down the features as

[jira] [Created] (FLINK-28189) The taskmanager dynamically created by flink native k8s creates pods directly, why not create a deployment?

2022-06-21 Thread hob007 (Jira)
hob007 created FLINK-28189: -- Summary: The taskmanager dynamically created by flink native k8s creates pods directly, why not create a deployment? Key: FLINK-28189 URL: https://issues.apache.org/jira/browse/FLINK-28189

[jira] [Created] (FLINK-28188) Documentation: Wrong default value for classloader.parent-first-patterns.default

2022-06-21 Thread Arseniy Tashoyan (Jira)
Arseniy Tashoyan created FLINK-28188: Summary: Documentation: Wrong default value for classloader.parent-first-patterns.default Key: FLINK-28188 URL: https://issues.apache.org/jira/browse/FLINK-28188

Re: Re: [ANNOUNCE] New Apache Flink Committers: Qingsheng Ren, Shengkai Fang

2022-06-21 Thread Mason Chen
Awesome work Qingsheng and Shengkai! Best, Mason On Tue, Jun 21, 2022 at 4:53 AM Zhipeng Zhang wrote: > Congratulations, Qingsheng and ShengKai. > > Yang Wang 于2022年6月21日周二 19:43写道: > > > Congratulations, Qingsheng and ShengKai. > > > > > > Best, > > Yang > > > > Benchao Li 于2022年6月21日周二

[jira] [Created] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-21 Thread Jeesmon Jacob (Jira)
Jeesmon Jacob created FLINK-28187: - Summary: Duplicate job submission for FlinkSessionJob Key: FLINK-28187 URL: https://issues.apache.org/jira/browse/FLINK-28187 Project: Flink Issue Type:

[jira] [Created] (FLINK-28186) Trigger Operator Events on Configuration Changes

2022-06-21 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-28186: - Summary: Trigger Operator Events on Configuration Changes Key: FLINK-28186 URL: https://issues.apache.org/jira/browse/FLINK-28186 Project: Flink Issue

[jira] [Created] (FLINK-28185) "Invalid negative offset" when using OffsetsInitializer.timestamp(.)

2022-06-21 Thread Peter Schrott (Jira)
Peter Schrott created FLINK-28185: - Summary: "Invalid negative offset" when using OffsetsInitializer.timestamp(.) Key: FLINK-28185 URL: https://issues.apache.org/jira/browse/FLINK-28185 Project:

[jira] [Created] (FLINK-28184) LogStoreE2eTest is not stable

2022-06-21 Thread Jane Chan (Jira)
Jane Chan created FLINK-28184: - Summary: LogStoreE2eTest is not stable Key: FLINK-28184 URL: https://issues.apache.org/jira/browse/FLINK-28184 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28183) flink-python is lacking several test dependencies

2022-06-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-28183: Summary: flink-python is lacking several test dependencies Key: FLINK-28183 URL: https://issues.apache.org/jira/browse/FLINK-28183 Project: Flink

[jira] [Created] (FLINK-28182) Support Avro generic record decoder in PyFlink

2022-06-21 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-28182: - Summary: Support Avro generic record decoder in PyFlink Key: FLINK-28182 URL: https://issues.apache.org/jira/browse/FLINK-28182 Project: Flink Issue Type: New

[jira] [Created] (FLINK-28181) Add support in FlinkSessionJob to submit job using jar available in jobManager's classpath

2022-06-21 Thread Jeesmon Jacob (Jira)
Jeesmon Jacob created FLINK-28181: - Summary: Add support in FlinkSessionJob to submit job using jar available in jobManager's classpath Key: FLINK-28181 URL: https://issues.apache.org/jira/browse/FLINK-28181

[jira] [Created] (FLINK-28180) Unify Application and SessionJob reconcilers

2022-06-21 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28180: -- Summary: Unify Application and SessionJob reconcilers Key: FLINK-28180 URL: https://issues.apache.org/jira/browse/FLINK-28180 Project: Flink Issue Type:

[jira] [Created] (FLINK-28179) LeafPredicate accepts multiple literals

2022-06-21 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28179: Summary: LeafPredicate accepts multiple literals Key: FLINK-28179 URL: https://issues.apache.org/jira/browse/FLINK-28179 Project: Flink Issue Type:

Re: Please add me to the contributors list

2022-06-21 Thread Yankee
OK. Thanks. Yankee24 > 2022年6月21日 19:48,Martijn Visser 写道: > > Hi Yankee24, > > Thanks for reaching out. Please follow > https://flink.apache.org/contributing/contribute-code.html in order to > start with your contribution. We don't need to add you to any list in order > to get this started.

Re: [DISCUSS] Flink Kubernetes Operator release cadence proposal

2022-06-21 Thread Gyula Fóra
Hi Matyas! Thanks for starting the discussion. I think the 2 month release cycle sounds reasonable. I think it's important for users to have frequent operator releases as these affect all Flink jobs running in the environment. We should also only adopt a schedule that we can most likely keep. If

Re: Re: [ANNOUNCE] New Apache Flink Committers: Qingsheng Ren, Shengkai Fang

2022-06-21 Thread Zhipeng Zhang
Congratulations, Qingsheng and ShengKai. Yang Wang 于2022年6月21日周二 19:43写道: > Congratulations, Qingsheng and ShengKai. > > > Best, > Yang > > Benchao Li 于2022年6月21日周二 19:33写道: > > > Congratulations! > > > > weijie guo 于2022年6月21日周二 13:44写道: > > > > > Congratulations, Qingsheng and ShengKai! > >

Re: Please add me to the contributors list

2022-06-21 Thread Martijn Visser
Hi Yankee24, Thanks for reaching out. Please follow https://flink.apache.org/contributing/contribute-code.html in order to start with your contribution. We don't need to add you to any list in order to get this started. Best regards, Martijn Op di 21 jun. 2022 om 13:44 schreef Yankee : > Hi,

[jira] [Created] (FLINK-28178) Show the delegated StateBackend and whether changelog is enabled in the UI

2022-06-21 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-28178: --- Summary: Show the delegated StateBackend and whether changelog is enabled in the UI Key: FLINK-28178 URL: https://issues.apache.org/jira/browse/FLINK-28178 Project:

[jira] [Created] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

2022-06-21 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28177: Summary: Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable Key: FLINK-28177 URL:

Please add me to the contributors list

2022-06-21 Thread Yankee
Hi, Flink community I want to contribute some code to the Flink project. Please add me to the contributors list. My Jira account username is “Yankee24". Thanks. Yankee24

Re: Re: [ANNOUNCE] New Apache Flink Committers: Qingsheng Ren, Shengkai Fang

2022-06-21 Thread Yang Wang
Congratulations, Qingsheng and ShengKai. Best, Yang Benchao Li 于2022年6月21日周二 19:33写道: > Congratulations! > > weijie guo 于2022年6月21日周二 13:44写道: > > > Congratulations, Qingsheng and ShengKai! > > > > Best regards, > > > > Weijie > > > > > > Yuan Mei 于2022年6月21日周二 13:07写道: > > > > > Congrats

Re: Re: [ANNOUNCE] New Apache Flink Committers: Qingsheng Ren, Shengkai Fang

2022-06-21 Thread Benchao Li
Congratulations! weijie guo 于2022年6月21日周二 13:44写道: > Congratulations, Qingsheng and ShengKai! > > Best regards, > > Weijie > > > Yuan Mei 于2022年6月21日周二 13:07写道: > > > Congrats Qingsheng and ShengKai! > > > > Best, > > > > Yuan > > > > On Tue, Jun 21, 2022 at 11:27 AM Terry Wang wrote: > > > >

[jira] [Created] (FLINK-28176) test_es_sink_dynamic failed in jdk11

2022-06-21 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28176: Summary: test_es_sink_dynamic failed in jdk11 Key: FLINK-28176 URL: https://issues.apache.org/jira/browse/FLINK-28176 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28175) Improve LicenseChecker output

2022-06-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-28175: Summary: Improve LicenseChecker output Key: FLINK-28175 URL: https://issues.apache.org/jira/browse/FLINK-28175 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-28174) Dynamically resolve StatsD Reporter Host

2022-06-21 Thread Emile (Jira)
Emile created FLINK-28174: - Summary: Dynamically resolve StatsD Reporter Host Key: FLINK-28174 URL: https://issues.apache.org/jira/browse/FLINK-28174 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-28173) Multiple Parquet format tests are failing with NoSuchMethodError

2022-06-21 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-28173: -- Summary: Multiple Parquet format tests are failing with NoSuchMethodError Key: FLINK-28173 URL: https://issues.apache.org/jira/browse/FLINK-28173 Project: Flink

[jira] [Created] (FLINK-28172) Scatter dstl files into separate directories by job id

2022-06-21 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-28172: --- Summary: Scatter dstl files into separate directories by job id Key: FLINK-28172 URL: https://issues.apache.org/jira/browse/FLINK-28172 Project: Flink Issue

[jira] [Created] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS

2022-06-21 Thread Moshe Elisha (Jira)
Moshe Elisha created FLINK-28171: Summary: Adjust Job and Task manager port definitions to work with Istio+mTLS Key: FLINK-28171 URL: https://issues.apache.org/jira/browse/FLINK-28171 Project: Flink

[jira] [Created] (FLINK-28170) Python tests are taking more than 240 minutes to complete, causing timeouts

2022-06-21 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-28170: -- Summary: Python tests are taking more than 240 minutes to complete, causing timeouts Key: FLINK-28170 URL: https://issues.apache.org/jira/browse/FLINK-28170

[jira] [Created] (FLINK-28169) GlueSchemaRegistryJsonKinesisITCase fails on JDK11 due to NoSuchMethodError

2022-06-21 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-28169: -- Summary: GlueSchemaRegistryJsonKinesisITCase fails on JDK11 due to NoSuchMethodError Key: FLINK-28169 URL: https://issues.apache.org/jira/browse/FLINK-28169

[jira] [Created] (FLINK-28168) org.apache.flink.table.api.ValidationException: Data type 'ARRAY NOT NULL' does not support null values.

2022-06-21 Thread Jira
熊搏 created FLINK-28168: -- Summary: org.apache.flink.table.api.ValidationException: Data type 'ARRAY NOT NULL' does not support null values. Key: FLINK-28168 URL: https://issues.apache.org/jira/browse/FLINK-28168

[jira] [Created] (FLINK-28167) flink native k8s动态创建的taskmanager 直接创建pod,为啥不创建deployment?

2022-06-21 Thread hob007 (Jira)
hob007 created FLINK-28167: -- Summary: flink native k8s动态创建的taskmanager 直接创建pod,为啥不创建deployment? Key: FLINK-28167 URL: https://issues.apache.org/jira/browse/FLINK-28167 Project: Flink Issue Type:

[jira] [Created] (FLINK-28166) Configurable Automatic Retries on Error

2022-06-21 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-28166: - Summary: Configurable Automatic Retries on Error Key: FLINK-28166 URL: https://issues.apache.org/jira/browse/FLINK-28166 Project: Flink Issue Type:

[jira] [Created] (FLINK-28165) Remove include_hadoop_aws profile

2022-06-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-28165: Summary: Remove include_hadoop_aws profile Key: FLINK-28165 URL: https://issues.apache.org/jira/browse/FLINK-28165 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-221 Abstraction for lookup source cache and metric

2022-06-21 Thread Qingsheng Ren
Hi devs, I’d like to push FLIP-221 forward a little bit. Recently we had some offline discussions and updated the FLIP. Here’s the diff compared to the previous version: 1. (Async)LookupFunctionProvider is designed as a base interface for constructing lookup functions. 2. From the

[jira] [Created] (FLINK-28164) Introduce utilities API for REST endpint

2022-06-21 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28164: - Summary: Introduce utilities API for REST endpint Key: FLINK-28164 URL: https://issues.apache.org/jira/browse/FLINK-28164 Project: Flink Issue Type:

[DISCUSS] Flink Kubernetes Operator release cadence proposal

2022-06-21 Thread Őrhidi Mátyás
Hi Devs, After the successful Kubernetes Operator 1.0.0 release, which is considered to be the first production grade one, it is probably a good time now to also agree on a predictable release cadence for the Operator too, similarly to the time-based release plan we have for the Flink core

[jira] [Created] (FLINK-28163) Introduce the statement related API for REST endpoint

2022-06-21 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28163: - Summary: Introduce the statement related API for REST endpoint Key: FLINK-28163 URL: https://issues.apache.org/jira/browse/FLINK-28163 Project: Flink

[jira] [Created] (FLINK-28162) Introduce the operation-related API for REST endpoint

2022-06-21 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28162: - Summary: Introduce the operation-related API for REST endpoint Key: FLINK-28162 URL: https://issues.apache.org/jira/browse/FLINK-28162 Project: Flink

[jira] [Created] (FLINK-28161) Introduce the session related API for REST endpoint

2022-06-21 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-28161: - Summary: Introduce the session related API for REST endpoint Key: FLINK-28161 URL: https://issues.apache.org/jira/browse/FLINK-28161 Project: Flink Issue

[RESULT][VOTE] Deprecate SourceFunction API

2022-06-21 Thread Alexander Fedulov
Hi everyone, The proposal to deprecate SourceFunction API has been unanimously accepted [1]. There are 5 approving votes, 3 of which are binding: * Martijn Visser (binding) * Becket Qin (binding) * Qingsheng Ren (binding) * Jing Ge (non-binding) * Lijie Wang (non-binding) Thanks for

[jira] [Created] (FLINK-28160) org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled.

2022-06-21 Thread cjh (Jira)
cjh created FLINK-28160: --- Summary: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. Key: FLINK-28160 URL: https://issues.apache.org/jira/browse/FLINK-28160 Project: Flink