[jira] [Created] (FLINK-26345) Observer should detect flink job even if deployment status is empty

2022-02-23 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26345: -- Summary: Observer should detect flink job even if deployment status is empty Key: FLINK-26345 URL: https://issues.apache.org/jira/browse/FLINK-26345 Project: Flink

[jira] [Created] (FLINK-26344) waitForClusterShutdown does not work correctly in Flink Kubernetes operator

2022-02-23 Thread Yang Wang (Jira)
Yang Wang created FLINK-26344: - Summary: waitForClusterShutdown does not work correctly in Flink Kubernetes operator Key: FLINK-26344 URL: https://issues.apache.org/jira/browse/FLINK-26344 Project:

[jira] [Created] (FLINK-26343) IndexOutOfBoundsException when subquery select all field from using hive dialect

2022-02-23 Thread luoyuxia (Jira)
luoyuxia created FLINK-26343: Summary: IndexOutOfBoundsException when subquery select all field from using hive dialect Key: FLINK-26343 URL: https://issues.apache.org/jira/browse/FLINK-26343 Project:

Re: [DISCUSS] Plan to externalize connectors and versioning

2022-02-23 Thread Thomas Weise
This plan LGTM. Thanks, Thomas On Wed, Feb 23, 2022 at 4:28 AM Chesnay Schepler wrote: > > That sounds fine to me. > > On 23/02/2022 10:49, Konstantin Knauf wrote: > > Hi Chesnay, Hi everyone, > > > > I think the idea for the migration is the following (with the example of > > ElasticSearch). I

[jira] [Created] (FLINK-26342) Add missing CSV format page

2022-02-23 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-26342: - Summary: Add missing CSV format page Key: FLINK-26342 URL: https://issues.apache.org/jira/browse/FLINK-26342 Project: Flink Issue Type:

[jira] [Created] (FLINK-26341) ZooKeeperTestEnvironment does not allow for repeated test execution

2022-02-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26341: - Summary: ZooKeeperTestEnvironment does not allow for repeated test execution Key: FLINK-26341 URL: https://issues.apache.org/jira/browse/FLINK-26341 Project: Flink

Re: question about StatefunContext in golang Statefun SDK

2022-02-23 Thread Galen Warren
Great -- thanks for your help! PR created: [FLINK-26340][statefun-golang-sdk] Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context by galenwarren · Pull Request #303 · apache/flink-statefun (github.com)

Re: question about StatefunContext in golang Statefun SDK

2022-02-23 Thread Austin Cawley-Edwards
I agree with you Galen, adding a default implementation would not be so natural here. We could eventually change this from being an interface to just a struct (like http.Request) if there is no use case for custom implementations. Thanks for the nice discussion here + contribution :) Austin On

Re: question about StatefunContext in golang Statefun SDK

2022-02-23 Thread Galen Warren
Thanks, Till. > Is it possible in Go to provide a default implementation for a method? > Maybe that way the introduction of the new method would not be breaking. > I can't think of a way to do this that would be seamless to someone who had chosen to create a custom struct implementing

[jira] [Created] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

2022-02-23 Thread Galen Warren (Jira)
Galen Warren created FLINK-26340: Summary: Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context Key: FLINK-26340 URL:

[jira] [Created] (FLINK-26339) Introduce the webhook config to free the environment options

2022-02-23 Thread Aitozi (Jira)
Aitozi created FLINK-26339: -- Summary: Introduce the webhook config to free the environment options Key: FLINK-26339 URL: https://issues.apache.org/jira/browse/FLINK-26339 Project: Flink Issue

[jira] [Created] (FLINK-26338) Add documentation of savepoint type on Command-Line part

2022-02-23 Thread Yun Tang (Jira)
Yun Tang created FLINK-26338: Summary: Add documentation of savepoint type on Command-Line part Key: FLINK-26338 URL: https://issues.apache.org/jira/browse/FLINK-26338 Project: Flink Issue Type:

[jira] [Created] (FLINK-26337) Avoid load flink conf each reconcile loop

2022-02-23 Thread Aitozi (Jira)
Aitozi created FLINK-26337: -- Summary: Avoid load flink conf each reconcile loop Key: FLINK-26337 URL: https://issues.apache.org/jira/browse/FLINK-26337 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26336) Deletion should remove HA related configmaps also

2022-02-23 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26336: -- Summary: Deletion should remove HA related configmaps also Key: FLINK-26336 URL: https://issues.apache.org/jira/browse/FLINK-26336 Project: Flink Issue Type:

[jira] [Created] (FLINK-26335) prometheus/metrics - java.lang.OutOfMemoryError: Java heap space

2022-02-23 Thread Marcelo Nogueira (Jira)
Marcelo Nogueira created FLINK-26335: Summary: prometheus/metrics - java.lang.OutOfMemoryError: Java heap space Key: FLINK-26335 URL: https://issues.apache.org/jira/browse/FLINK-26335 Project:

[jira] [Created] (FLINK-26334) when watermark less than (0-offset) , T

2022-02-23 Thread realdengziqi (Jira)
realdengziqi created FLINK-26334: Summary: when watermark less than (0-offset) , T Key: FLINK-26334 URL: https://issues.apache.org/jira/browse/FLINK-26334 Project: Flink Issue Type: Bug

Re: [DISCUSS] Plan to externalize connectors and versioning

2022-02-23 Thread Chesnay Schepler
That sounds fine to me. On 23/02/2022 10:49, Konstantin Knauf wrote: Hi Chesnay, Hi everyone, I think the idea for the migration is the following (with the example of ElasticSearch). I talked to Martijn offline. 1. ElasticSearch Connector is released from the core repository with the Flink

[jira] [Created] (FLINK-26333) [Flink 1.14.3] Repeated exception with DuplicateJobSubmissionException: Job has already been submitted

2022-02-23 Thread Parag Somani (Jira)
Parag Somani created FLINK-26333: Summary: [Flink 1.14.3] Repeated exception with DuplicateJobSubmissionException: Job has already been submitted Key: FLINK-26333 URL:

[jira] [Created] (FLINK-26332) Move the Operator Env to the common Utils

2022-02-23 Thread Aitozi (Jira)
Aitozi created FLINK-26332: -- Summary: Move the Operator Env to the common Utils Key: FLINK-26332 URL: https://issues.apache.org/jira/browse/FLINK-26332 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] Flink 1.15 Feature Freeze

2022-02-23 Thread Till Rohrmann
Hi Fabian, Thanks for letting us know. I believe that it should be ok to merge this PR since it is only affecting the ES connector. Cheers, Till On Wed, Feb 23, 2022 at 10:54 AM Fabian Paul wrote: > Hi all, > > I would like to merge the following PR [1]. It has been approved > before the

[jira] [Created] (FLINK-26331) Make max retries configurable

2022-02-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-26331: - Summary: Make max retries configurable Key: FLINK-26331 URL: https://issues.apache.org/jira/browse/FLINK-26331 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] Flink 1.15 Feature Freeze

2022-02-23 Thread Fabian Paul
Hi all, I would like to merge the following PR [1]. It has been approved before the feature freeze but no one had time to merge it, unfortunately. The feature is very contained and only adds a simple capability to the Elastic connector when used with Flink SQL. If there are no concerns until end

[jira] [Created] (FLINK-26330) Test Adaptive Batch Scheduler manually

2022-02-23 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-26330: -- Summary: Test Adaptive Batch Scheduler manually Key: FLINK-26330 URL: https://issues.apache.org/jira/browse/FLINK-26330 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Plan to externalize connectors and versioning

2022-02-23 Thread Konstantin Knauf
Hi Chesnay, Hi everyone, I think the idea for the migration is the following (with the example of ElasticSearch). I talked to Martijn offline. 1. ElasticSearch Connector is released from the core repository with the Flink 1.15.0 release. No changes. 2. At the beginning of the Flink 1.16 release

[jira] [Created] (FLINK-26329) Adjust the order of var initialization in FlinkControllerConfig

2022-02-23 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-26329: Summary: Adjust the order of var initialization in FlinkControllerConfig Key: FLINK-26329 URL: https://issues.apache.org/jira/browse/FLINK-26329 Project: Flink

[jira] [Created] (FLINK-26328) Control Logging Behavior in Flink Deployments

2022-02-23 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-26328: - Summary: Control Logging Behavior in Flink Deployments Key: FLINK-26328 URL: https://issues.apache.org/jira/browse/FLINK-26328 Project: Flink Issue Type:

[jira] [Created] (FLINK-26327) throw not a literal exception in callContext.getArgumentValue when getTypeInference

2022-02-23 Thread Spongebob (Jira)
Spongebob created FLINK-26327: - Summary: throw not a literal exception in callContext.getArgumentValue when getTypeInference Key: FLINK-26327 URL: https://issues.apache.org/jira/browse/FLINK-26327

[jira] [Created] (FLINK-26326) FLIP-203: Support native and incremental savepoints 1.1

2022-02-23 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-26326: - Summary: FLIP-203: Support native and incremental savepoints 1.1 Key: FLINK-26326 URL: https://issues.apache.org/jira/browse/FLINK-26326 Project: Flink

[jira] [Created] (FLINK-26325) Add test coverage for native format State Processor API

2022-02-23 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-26325: - Summary: Add test coverage for native format State Processor API Key: FLINK-26325 URL: https://issues.apache.org/jira/browse/FLINK-26325 Project: Flink

[jira] [Created] (FLINK-26324) Remove duplicate condition judgment

2022-02-23 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-26324: Summary: Remove duplicate condition judgment Key: FLINK-26324 URL: https://issues.apache.org/jira/browse/FLINK-26324 Project: Flink Issue Type: Improvement

Re: question about StatefunContext in golang Statefun SDK

2022-02-23 Thread Till Rohrmann
Thanks a lot for the discussion Austin and Galen. I think it would be fine to break the API at this point in time. Moreover, I don't assume that many people have their own statefun.Context implementations. Is it possible in Go to provide a default implementation for a method? Maybe that way the

Re: Re: [ANNOUNCE] New Apache Flink Committers: Feng Wang, Zhipeng Zhang

2022-02-23 Thread Marios Trivyzas
Congrats!!! On Tue, Feb 22, 2022, 05:12 Yun Gao wrote: > Congratulations Feng and Zhipeng! > > Best, > Yun > > > -- > From:Jing Zhang > Send Time:2022 Feb. 18 (Fri.) 22:22 > To:dev > Subject:Re: Re: [ANNOUNCE] New Apache Flink

[jira] [Created] (FLINK-26323) PerJobMiniClusterFactoryTest.testJobClient failed on azure

2022-02-23 Thread Yun Gao (Jira)
Yun Gao created FLINK-26323: --- Summary: PerJobMiniClusterFactoryTest.testJobClient failed on azure Key: FLINK-26323 URL: https://issues.apache.org/jira/browse/FLINK-26323 Project: Flink Issue Type: