I opened up https://github.com/ryan-williams/beam/pull/1 against your branch with suggestions on how to fix up tests. Effectively I changed everything to use a primitive transform URN.
@tweise I'm not sure how you implemented native sources/sinks in your Flink integration but this change will mean that you will need to use a primitive urn like read/pardo without an environment as the way to signal to Flink that it should intercept this transform and replace it with its own implementation. [ Full content available at: https://github.com/apache/beam/pull/6328 ] This message was relayed via gitbox.apache.org for [email protected]
