Please see FLINK-14184 <https://issues.apache.org/jira/browse/FLINK-14184> which should fully support such use cases in the future. Feel free to vote for it if you believe it would help your use case.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/