Hi, one question - it seems that "barriers" are perfectly supported by Flink, but not yet supported in Flink SQL.
When I e.g. do a UNION of two views derived from one source table fed by Kafka, I get thousands of intermediate results which are incorrect (the example I am using is this one: https://www.scattered-thoughts.net/writing/internal-consistency-in-streaming-systems/), and I can only be sure to get the correct result if I stop producing new messages into the source table. 1) Is my understanding correct that barriers are not implemented for Flink SQL? 2) Why is it not implemented/is this on the roadmap? Best, Ralph
