Unable to implement custom tuple deserialiser

Hi Team, I am trying to implement the custom deserializer class for tuple type. I have explained my problem here on this link . Any help i

Difference between different timestamps

hello team, I want to understand if context.timestamp() of ProcessFunction is the same as context.current_processing_time()/ window().start of ProcessWindowFunction? Thanks.

Rolling back a bad deployment of FlinkDeployment on kubernetes

Hi Flink Community, I am currently running Apache flink-kubernetes-operator on our kubernetes clusters, and I have Flink applications that are deployed using the FlinkDeployment Custom Resources (CR). I am trying to automate the process of rollbacks and I am running into some issues. I was testin

Re: Pyflink unittest cases

. On Mon, Oct 2, 2023 at 9:21 PM joshua perez wrote: > Hello folks, > > Any help is appreciated. > > J. > > On Sat, Sep 30, 2023 at 1:47 PM joshua perez wrote: > >> Hi Team, >> >> We recently have started a use case where there would be involvement of >> Kafka and Flink's low level APIs like ma

PyFlink MapState with Types.ROW() throws exception

Hi Flinkers, I'm trying to use MapState, where the value will be a list of type elements. Wanted to check if anyone else faced the same issue while trying to use MapState in PyFlink with complex types. Here is the code: from pyflink.common import Time from pyflink.common.typeinfo import Types

Issues using savepoint upgradeMode with Kubernetes Operator

Hello, For one, excellent work on the K8s Operator, which works extremely well. However, I am having an issue that I can't seem to resolve where setting the upgradeMode to savepoint simply doesn't work. For example, suppose I submit a job using FlinkDeployment like so: job: entryClass: "org.a