SteNicholas commented on pull request #13853:
URL: https://github.com/apache/flink/pull/13853#issuecomment-719462500


   @aljoscha , sorry for my bad implementations. I agree with the steps you 
provided that use `assignTimestampsAndWatermarks()` logical operation instead 
of creating an operator directly in `assignTimestampsAndWatermarks()` and add a 
`TransformationTranslator`. I would like to follow your comments of this 
implementations immediately. Thanks to your detailed suggestion.


----------------------------------------------------------------
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]


Reply via email to