Backpressure causing operators to stop ingestion completely

Hello, I have an aggregator job that experiences backpressure after running for a while and completely stops processing. It doesn't take any further input from the source. Here's a bit of context: - There are 3 producer jobs, all of which write data to a common Kafka topic - The aggregator job r

Backporting array_agg from 1.20 to 1.18

Hello 👋  At my company we have a Flink SQL job that necessitates the `array_agg` function that was introduced in version 1.20 (this is the only documentation I could find: ).