Flink-kubernetes-operator with Argocd

Hi, Can anyone who has implemented flink-kubernetes-operator with Argocd share an example code? Thank you, Sweta --

Re: Recover watermark from savepoint

(because watermarks are delayed by the auto > watermark interval, rather than being produced at every conceivable > opportunity). > > > > If this is a strong requirement, you could decide not to rely on > watermarks for dropping late events, and implement the logic yourself

Re: slack invite link

Hi, Please add me to the slack channel. Thanks, Sweta On Sun, Jun 5, 2022 at 6:42 AM Jing Ge wrote: > Hi, > > Invites have been sent. Please check your emails. Thanks! > > Regards, > JIng > > On Sun, Jun 5, 2022 at 12:38 PM Jay Ghiya wrote: > >> Request community to share invite link for me

Recover watermark from savepoint

Hi, I want to understand if flink saves a watermark during savepoint and if not, how do we achieve this? We are seeing an issue where on recovery, the job processes some late events which should have been discarded if the job were to be running without any downtime. Thank you, Sweta

Re: Issue with Flink UI for Flink 1.14.0

I am facing the same issue, do we know when 1.14.4 will be released? Thanks. On Fri, Jan 21, 2022 at 3:28 AM Chesnay Schepler wrote: > While FLINK-24550 was indeed fixed unfortunately a similar bug was also > introduced (https://issues.apache.org/jira/browse/FLINK-25732). > On 20/01/2022

Re: Upgrade to 1.14.3

ne; I assume this is what you are seeing. > > Did you make sure to update the connector (and any other) dependencies > as well? > > > Best > Ingo > > On 25.01.22 05:36, Sweta Kalakuntla wrote: > > Hi, > > > > We are on flink 1.13.3 and trying to upgrade th

Upgrade to 1.14.3

Hi, We are on flink 1.13.3 and trying to upgrade the cluster to 1.14.3 version. I see that job(on 1.13.3) is unable to start up because it says it couldn't find metrics group(inside flinkkafkaconsumer class). - can I deploy 1.13.3 job on 1.14.3 cluster? - can I deploy 1.14.3 job on 1.13.3

Broadcast and watermark

Hi, I am using a broadcast pattern for publishing rules and aggregating the data(https://flink.apache.org/news/2020/01/15/demo-fraud-detection.html). My use case is similar and also the code. One thing I wanted to capture is to figure out any latevents if any and send them to a sink. But when

Re: Upgrade from 1.13.1 to 1.13.2/1.13.3 failing

ntly we don't > know why you are experiencing this issue. > > On 22/10/2021 16:02, Sweta Kalakuntla wrote: > > Hi, > > We are seeing error while upgrading minor versions from 1.13.1 to 1.13.2. > JobManager is unable to recover the checkpoint state. What would be the >

Upgrade from 1.13.1 to 1.13.2/1.13.3 failing

Hi, We are seeing error while upgrading minor versions from 1.13.1 to 1.13.2. JobManager is unable to recover the checkpoint state. What would be the solution to this issue? Caused by: org.apache.flink.util.FlinkException: Could not retrieve checkpoint 2844 from state handle under

Re: Can we share state between different keys in the same window?

rrent key in > `ProcessFunction`/`KeyedProcessFunction`/`ProcessWindowFunction`, there is > no possible to read/write state of other keys. > > Would you please describe your business demand, let's see if there is > other way to satisfy the requirement. > > Best, > JING ZHANG &

Can we share state between different keys in the same window?

Hi, I need to query the database(not a source but for additional information) in ProcessFunction. I want to save the results in a state or some other way so that I can use the data for other keys in the same window. What are my options? Thanks, sweta

Session cluster configmap removal

Hi, We have flink session clusters in kubernetes and several long running flink jobs deployed in them with HA enabled. After we have enabled HA, we are seeing configmaps created for every new job. Whenever we stop/cancel any existing jobs, these configmaps do not get deleted. Is that right, these

Flink jobs organization and maintainability

Hi, I am going to have to implement many similar jobs. I need guidance and examples that you may have for organizing them in the Git repository without having to have one repo per job. Thanks, SK --

Flink Kafka Table API for python with JAAS

ot;org.apache.kafka.common.security.plain.PlainLoginModule required username=\"user\" " "password=\"abc\";")\ .start_from_latest() Thank you, SKala -- [image: BandwidthBlue.png] Sweta Kalakuntla • Software Engineer 900 Main Campus Drive, Raleigh, NC 27606 m: 216-702-1653 e: skalakun...@bandwidth.com