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