Thanks for sharing your thoughts, Gyula!
>Not really sure what you are trying to achieve with it , maybe some other
audit feature would be enough to simply track the spec changes over time of
the CR?
Basically we wanted to leverage Flink history server to know the details /
insights(e.g. DAG/opera
Hi getting this exception, a lot of resources online point to an SSL
misconfiguration.
We are NOT using SSL. Neither on the broker or the consumer side. Our jobs
work absolutely fine as in the flink task is able to consume from kafka
parse the json and then push it to the JDBC database sink.
I wo
Hi, we have an error when Flink 1.20 resume a job from a savepoint that was
written with Flink 1.19 (We are in an upgrade scenario here). And we hit the
error `Caused by: java.lang.ClassNotFoundException:
org.apache.flink.runtime.jobgraph.RestoreMode`, see below
So I get that `org.apache.flink.
For those who would look for an answer, the fix is available in 1.18:
https://issues.apache.org/jira/browse/FLINK-31498
Proposed solution is not to request for TaskManagers if there are some
slots already pending.
On Thu, Jul 4, 2024 at 2:00 PM Alex Nitavsky wrote:
> Hello community,
>
> I need
