Re: Flink operator - ignore ssl cert validation

Exactly...I was hoping there's an easy way to inject this option on the http client of artifact fetcher. Resolved this by adding the cert to the cert store, so needed to build a custom image.  On Thursday, June 23, 2022, 06:03:21 AM EDT, Őrhidi Mátyás wrote: I guess the problem is cau

Re: Flink Operator - Support for k8s HA jobmanager

Thank you all for the feedback. It's now working mounted with EFS volume.  On Thursday, June 23, 2022, 05:33:11 AM EDT, Yang Wang wrote: Matyas's answer is on the point. You need to mount a shared volume for all the JobManager pods so that the uploaded jars are visible for them all. Be

How to make current application cdc

Hello, I have a current flow where the data from the Flink-Kafka connector is captured and processed using Flink Datastream API and stored in Kafka topics. However, I would like to make it CDC enabled. I went through an article where it was mentioned that it should be handled on the Kafka side whi