Github user sijie commented on the issue: https://github.com/apache/flink/pull/5845 @tzulitai thank you very much for you help. just sent an email to dev@flink. look forward to feedback from flink community and collaboration between flink and pulsar communities.
---