@pnowojski Agree, then I will first refactor the duplicate code based on 1.0, then add the 1.1 module. In fact, 2.0 is also in the process of being prepared, but it is still on another branch of my locality.
[ Full content available at: https://github.com/apache/flink/pull/6577 ] This message was relayed via gitbox.apache.org for [email protected]
