Flink state statistics

2024-12-02 Thread Christian Lorenz via user
Hi, is there a way to receive some basic statistics of a named value-state in flink? Besides, is the assumption correct that a call to org.apache.flink.api.common.state.State#clear is removing the state also from the checkpoint data? We had to use some long TTL time and am uncertain if the data

AW: Can we share states across tasks/operators

2024-08-09 Thread Christian Lorenz via user
Hi Matthias, I am facing a similar issue with the need to have state on 2 keyed input streams, but the state can only be cleared with events occurring in a third input stream. Do you have maybe some examples how to utilize MultipleInputStreamOperator you have mentioned? Thanks and kind regards

Flink 1.17.2 planned?

2023-08-21 Thread Christian Lorenz via user
Hi team, are there any infos about a bugfix release 1.17.2 available? E.g. will there be another bugfix release of 1.17 / approximate timing? We are hit by https://issues.apache.org/jira/browse/FLINK-32296 which leads to wrong SQL responses in some circumstances. Kind regards, Christian This e-

Cancel a job in status INITIALIZING

2022-09-21 Thread Christian Lorenz via user
Hi, we’re running a Flink Cluster in standalone/session mode. During a restart of a jobmanager one job was stuck in status INITIALIZING. When trying to cancel the job via CLI the command failed with a java.util.concurrent.TimeoutException. The only way to get rid of this job for us was to stop t