[jira] [Created] (FLINK-32104) stop-with-savepoint fails and times out with simple reproducible example

2023-05-15 Thread Kurt Ostfeld (Jira)
Kurt Ostfeld created FLINK-32104: Summary: stop-with-savepoint fails and times out with simple reproducible example Key: FLINK-32104 URL: https://issues.apache.org/jira/browse/FLINK-32104 Project: Fli

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

2023-05-15 Thread Lijie Wang
Hi Karthi, I think you are using a wrong FLIP id, the FLIP-229 has already be used[1]. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-229%3A+Introduces+Join+Hint+for+Flink+SQL+Batch+Job Best, Lijie Martijn Visser 于2023年5月16日周二 04:44写道: > Hi Karthi, > > Thanks for the FLIP and open

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.5.0, release candidate #2

2023-05-15 Thread Jim Busche
+1 (Non-binding) I tested the following: - helm repo install from flink-kubernetes-operator-1.5.0-helm.tgz (See note 1 below) - podman Dockerfile build from source, looked good. (See note 2 below) - twistlock vulnerability scans of proposed ghcr.io/apache/flink-kubernetes-operator:be07be7 looks

[jira] [Created] (FLINK-32103) RBAC flinkdeployments/finalizers missing for OpenShift Deployment

2023-05-15 Thread James Busche (Jira)
James Busche created FLINK-32103: Summary: RBAC flinkdeployments/finalizers missing for OpenShift Deployment Key: FLINK-32103 URL: https://issues.apache.org/jira/browse/FLINK-32103 Project: Flink

Re: [DISCUSS] FLIP-229: Prometheus Sink Connector

2023-05-15 Thread Martijn Visser
Hi Karthi, Thanks for the FLIP and opening up the discussion. My main question is: why should we create a separate connector and not use and/or improve the existing integrations with Prometheus? I would like to understand more so that it can be added to the motivation of the FLIP. Best regards,

[DISCUSS] FLIP-229: Prometheus Sink Connector

2023-05-15 Thread Karthi Thyagarajan
Hello all,We would like to start a discussion thread on FLIP-229: Prometheus Sink Connector [1] where we propose to provide a sink connector for Prometheus [2] based on the Async Sink [3]. Looking forward to comments and feedback. Thank you.[1] https://cwiki.apache.org/confluence/display/FLINK

[jira] [Created] (FLINK-32102) Aggregate multiple pendingRecords metric per source if present

2023-05-15 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-32102: -- Summary: Aggregate multiple pendingRecords metric per source if present Key: FLINK-32102 URL: https://issues.apache.org/jira/browse/FLINK-32102 Project: F

[jira] [Created] (FLINK-32101) FlinkKafkaInternalProducerITCase.testInitTransactionId test failed

2023-05-15 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-32101: - Summary: FlinkKafkaInternalProducerITCase.testInitTransactionId test failed Key: FLINK-32101 URL: https://issues.apache.org/jira/browse/FLINK-32101 Project: Flink

Request for Feedback: Adding Command to List Flink Savepoints

2023-05-15 Thread Surendra Singh Lilhore
Hello everyone, I would like to propose an enhancement to Flink that would allow users to list Flink savepoints directly through a built-in command, eliminating the need to depend on external tools like the Flink CLI or file system commands. The motivation behind this feature is to simplify the p

Re: How to pass the TLS certs to the latest version of flink-connector-pulsar

2023-05-15 Thread Bauddhik Anand
Can someone please help with this? On Mon, 15 May, 2023, 09:34 Bauddhik Anand, wrote: > I am trying to connect my Flink application to a Pulsar topic for > ingesting data. The topic is active and i am able to ingest the data via a > normal Java application. > > When i try to use the Flink applic

[jira] [Created] (FLINK-32100) Max parallelism is incorrectly calculated with multiple topics

2023-05-15 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-32100: -- Summary: Max parallelism is incorrectly calculated with multiple topics Key: FLINK-32100 URL: https://issues.apache.org/jira/browse/FLINK-32100 Project: F

Re: [DISCUSS] Release Flink 1.17.1

2023-05-15 Thread Lijie Wang
+1 for the release. Best, Lijie Jing Ge 于2023年5月15日周一 17:07写道: > +1 for releasing 1.17.1 > > Best Regards, > Jing > > On Thu, May 11, 2023 at 10:03 AM Martijn Visser > wrote: > > > +1, thanks for volunteering! > > > > On Thu, May 11, 2023 at 9:23 AM Xintong Song > > wrote: > > > > > +1 > > >

Re: [DISCUSS] Release Flink 1.17.1

2023-05-15 Thread Jing Ge
+1 for releasing 1.17.1 Best Regards, Jing On Thu, May 11, 2023 at 10:03 AM Martijn Visser wrote: > +1, thanks for volunteering! > > On Thu, May 11, 2023 at 9:23 AM Xintong Song > wrote: > > > +1 > > > > I'll help with the steps that require PMC privileges. > > > > Best, > > > > Xintong > > >

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.5.0, release candidate #2

2023-05-15 Thread Gyula Fóra
+1 (binding) Verified the following: - Source files, checksums, signatures - Helm chart points to correct tag, deployed with and without HA - Deployed stateful application, performed upgrade, deletion, logs contain nothing unexpected - Checked release notes and maven repo contents Confirmed t

[jira] [Created] (FLINK-32099) create flink_data volume for operations playground

2023-05-15 Thread David Anderson (Jira)
David Anderson created FLINK-32099: -- Summary: create flink_data volume for operations playground Key: FLINK-32099 URL: https://issues.apache.org/jira/browse/FLINK-32099 Project: Flink Issue

[jira] [Created] (FLINK-32098) Dispatcher#submitJob calls Dispatcher#isInGloballyTerminalState up to three times which might be expensive due to IO

2023-05-15 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32098: - Summary: Dispatcher#submitJob calls Dispatcher#isInGloballyTerminalState up to three times which might be expensive due to IO Key: FLINK-32098 URL: https://issues.apache.org/ji

[jira] [Created] (FLINK-32097) Implement support for Kinesis aggregation

2023-05-15 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32097: --- Summary: Implement support for Kinesis aggregation Key: FLINK-32097 URL: https://issues.apache.org/jira/browse/FLINK-32097 Project: Flink Issue Type: S

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.5.0, release candidate #2

2023-05-15 Thread Gyula Fóra
Thank you Jim! Based on this workaround I would not necessarily consider this a blocker for the release but if we find any issues we can definitely include the fix in the next RC. @Tamir Sagi : It would be great to understand whether these issues are regressions compared to the 1.4.0 operator ve

[jira] [Created] (FLINK-32096) Flink 1.17 doc points to non-existant branch in flink-training repo

2023-05-15 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-32096: -- Summary: Flink 1.17 doc points to non-existant branch in flink-training repo Key: FLINK-32096 URL: https://issues.apache.org/jira/browse/FLINK-32096 Project: Flink