[jira] [Created] (FLINK-32105) Add apache/flink-training release to docs about creating a Flink release

Matthias Pohl created FLINK-32105: - Summary: Add apache/flink-training release to docs about creating a Flink release Key: FLINK-32105 URL: https://issues.apache.org/jira/browse/FLINK-32105 Project: F

[jira] [Created] (FLINK-32106) Unstable connection to archive.apache.org on AZP

Sergey Nuyanzin created FLINK-32106: --- Summary: Unstable connection to archive.apache.org on AZP Key: FLINK-32106 URL: https://issues.apache.org/jira/browse/FLINK-32106 Project: Flink Issue

[jira] [Created] (FLINK-32107) Kubernetes test failed because ofunable to establish ssl connection to github on AZP

Sergey Nuyanzin created FLINK-32107: --- Summary: Kubernetes test failed because ofunable to establish ssl connection to github on AZP Key: FLINK-32107 URL: https://issues.apache.org/jira/browse/FLINK-32107

[jira] [Created] (FLINK-32108) KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message

Matthias Pohl created FLINK-32108: - Summary: KubernetesExtension calls assumeThat in @BeforeAll callback which doesn't print the actual failure message Key: FLINK-32108 URL: https://issues.apache.org/jira/browse/F

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

Hi, Did you try set 'serviceurl' starts with "pulsar+ssl://"? [1] [1] https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/pulsar/#pulsar-client-serviceurl Best, Weihua On Mon, May 15, 2023 at 7:22 PM Bauddhik Anand wrote: > Can someone please help with this?

Maven plugin to detect issues early on

Hello all, Myself and 2 colleagues developed a Maven plugin (no support for Gradle or other build tools yet) that we use internally to detect potential issues in Flink apps at compilation/packaging stage: * Known connector version incompatibilities – so far covering Kafka and Kinesis *

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

Thanks for your response. Yes service url, admin url, topic etc are correct and have correct prefix as well. It is working with normal java application. I am not sure how i can pass the TLS certs. On Tue, 16 May, 2023, 14:52 Weihua Hu, wrote: > Hi, > > Did you try set 'serviceurl' starts w

[jira] [Created] (FLINK-32109) Operator doesn't recognize JobManager stuck on volumeMount startup errors

Gyula Fora created FLINK-32109: -- Summary: Operator doesn't recognize JobManager stuck on volumeMount startup errors Key: FLINK-32109 URL: https://issues.apache.org/jira/browse/FLINK-32109 Project: Flink

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

+1 (binding) 1. Downloaded the archives, checksums, and signatures 2. Verified the signatures and checksums 3. Extract and inspect the source code for binaries 4. Verified license files / headers 5. Compiled and tested the source code via mvn verify 6. Deployed helm chart to test cluster 7. Ran ex

[jira] [Created] (FLINK-32110) TM native memory leak when use time window in Pyflink ThreadMode

Yunjun Luo created FLINK-32110: -- Summary: TM native memory leak when use time window in Pyflink ThreadMode Key: FLINK-32110 URL: https://issues.apache.org/jira/browse/FLINK-32110 Project: Flink

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

Thank you, team. +1 (binding) - Verified Helm repo works as expected, points to correct image tag, build, version - Verified basic examples + checked operator logs everything looks as expected - Verified hashes, signatures and source release contains no binaries - Ran built-in tests, built jars +

Re: [DISCUSS] Status of Statefun Project

Hi Martijn, since you opened this discussion thread, I'm curious what your thoughts are in light of the responses? Thanks. On Wed, Apr 19, 2023 at 1:21 PM Galen Warren wrote: > I use Apache Flink for stream processing, and StateFun as a hand-off point >> for the rest of the application. >> It se

Re: [DISCUSS] Release Flink 1.17.1

Hi! Thanks for doing this release. I'm looking forward to some of the bug fixes, is there a date set for the release of 1.17.1? On Mon, May 15, 2023 at 6:10 AM Lijie Wang wrote: > +1 for the release. > > Best, > Lijie > > Jing Ge 于2023年5月15日周一 17:07写道： > > > +1 for releasing 1.17.1 > > > > Best

[jira] [Created] (FLINK-32111) Replacing cluster in failed state with a new one failed

Tamir Sagi created FLINK-32111: -- Summary: Replacing cluster in failed state with a new one failed Key: FLINK-32111 URL: https://issues.apache.org/jira/browse/FLINK-32111 Project: Flink Issue Typ

[jira] [Created] (FLINK-32112) Fixed State Backend sample config in zh-doc

ZhouXianming created FLINK-32112: Summary: Fixed State Backend sample config in zh-doc Key: FLINK-32112 URL: https://issues.apache.org/jira/browse/FLINK-32112 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-32113) TtlMapStateAllEntriesTestContext failure in generic types

Matthias Pohl created FLINK-32113: - Summary: TtlMapStateAllEntriesTestContext failure in generic types Key: FLINK-32113 URL: https://issues.apache.org/jira/browse/FLINK-32113 Project: Flink I

Re: [NOTICE] Flink master branch now uses Maven 3.8.6

Thanks a lot Chesnay for getting this squared away! It was quite painful to have to keep an outdated maven around specifically for building Flink but many had probably given up on this by now ;-) On Sun, May 14, 2023 at 9:33 PM yuxia wrote: > Thanks Chesnay for the efforts. Happy to see we can

Help regarding Setup flink-kubernetes-operator in EKS

Hi Team, I am really new to Flink, Kubernetes and I wanted to set up flink-kubernetes-operator in AWS EKS. I found this Repo which looks somehow similar. As I am new to all this thing, currently I am unable to relate this to how I can proceed a

Re: [DISCUSS] Release Flink 1.17.1

Hi Kevin, If everything goes smoothly, I will release the RC1 version of 1.17.1 this Thursday or Friday. Best regards, Weijie Kevin Lam 于2023年5月16日周二 22:53写道： > Hi! Thanks for doing this release. I'm looking forward to some of the bug > fixes, is there a date set for the release of 1.17.1? >

Re: [DISCUSS] Release Flink 1.16.2

Hi All, Thank you for your feedback! As there are no other concerns or objections, and currently I am not aware of any unresolved blockers. I will kick off the release process and start preparing for the RC1 version today. Best regards, Weijie Martijn Visser 于2023年5月11日周四 16:03写道： > +1 - m

[jira] [Created] (FLINK-32114) Extend FailureEnricherContext with task specific fields

Panagiotis Garefalakis created FLINK-32114: -- Summary: Extend FailureEnricherContext with task specific fields Key: FLINK-32114 URL: https://issues.apache.org/jira/browse/FLINK-32114 Project: F

[jira] [Created] (FLINK-32115) json_value support cache

xiaogang zhou created FLINK-32115: - Summary: json_value support cache Key: FLINK-32115 URL: https://issues.apache.org/jira/browse/FLINK-32115 Project: Flink Issue Type: Improvement