Unsubscribe

Unsubscribe

Unsubscribe

Unsubscribe

Local State Storage

Hi Team, I wanted to confirm, the local state which TM stores in the directory either we provide through config or default i.e. /tmp folder, does it clear itself from time to time or the size just keeps on increasing? Thanks Regards Amenreet Singh Sodhi

Flink in HA mode causing JM Failure

Hi All, I am deploying Flink cluster on Kubernetes in HA mode. But i noticed, whenever i deploy Flink cluster for first time on K8s cluster, it is not able to populate the cluster configmap, and due to which JM fails with the following exception: 2023-07-06 16:46:11,428 ERROR org.apache.flink.runt

Re: Flink compatibility with JDK17

atibility at > https://issues.apache.org/jira/browse/FLINK-15736. The biggest problem is > the Kryo serializer that's currently being used. That doesn't work with > JDK17, but upgrading would break compatibility so is not trivial. > > Best regards, > > Martijn > &g

Flink compatibility with JDK17

Hi, I wanted to confirm if Apache Flink is compatible with JDK17. If not, when can we expect this to happen? What major issues will I face if I try to compile it with JDK17? Thanks Regards Amenreet Singh Sodhi

Re: Flink Job Restarts if the metadata already exists for some Checkpoint

tart the job without before state ? >> The new job cannot know anything about before checkpoints, that's why the >> new job will fail when it tries to generate a new checkpoint. >> I'd like to suggest you to use different JOB_ID for different jobs, or >> set a diffe

Re: Flink Job Restarts if the metadata already exists for some Checkpoint

>>> The new job cannot know anything about before checkpoints, that's why >>> the new job will fail when it tries to generate a new checkpoint. >>> I'd like to suggest you to use different JOB_ID for different jobs, or >>> set a different checkpoint d

Flink Job Restarts if the metadata already exists for some Checkpoint

Hi all, Is there any way to prevent restart of flink job, or override the checkpoint metadata, if for some reason there exists a checkpoint by same name. I get the following exception and my job restarts, have been trying to find solution for a very long time but havent found anything useful yet,

Failed Kafka Offset Commit

Hi all, Hi Team, I am deploying my job in application mode on Flink-1.16.0, but keep constantly receiving this error from a long time: 2023-04-10 13:48:39,366 INFO org.apache.kafka.clients.NetworkClient [] - [Consumer clientId=event-executor-client-1, groupId=event-executor-gr