becketqin commented on pull request #12122: URL: https://github.com/apache/flink/pull/12122#issuecomment-629789714
@TsReaper I am fixing the compilation error. It was because a recent commit changed the interface of SourceOperator. From what I understand, all the operators will be provided through factories in the future. So does the sink. In that we may have to introduce a new method in the `DataStream` API in order to let the Sink leverage this mechanism. In terms of the `Table.collect()`. I think some modifications need to be made to `StreamGraphGenerator.transformSink()` and `StreamGraph.addSink()` to pass in the coordinator provider. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
