Hey everyone,
I raised this JIRA Issue a few months ago:
https://issues.apache.org/jira/browse/FLINK-32631 and it has not been picked yet. I may try to contribute a fix but wondering what will be the right solution here or if a solution already exists for it.
Any suggestions on this will be appreciated.