Dear Igal, Can you elaborate more on your proposed solution of splitting the pipeline?
If possible, providing some skeleton pseudocode would be awesome! Thanks in advance. Best, Max -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/