Github user tweise commented on the issue:

    https://github.com/apache/flink/pull/5634
  
    This is a good proposal, it should also survive a general connector 
refactor that will be necessary to address other code duplication. The Kinesis 
ticket is https://issues.apache.org/jira/browse/FLINK-5697 and I will add a 
reference back to this thread. I would be happy to add the watermark support 
based on the revised generator. Perhaps it would be good to recognize the 
special "idle" watermark in SourceContext also?


---

Reply via email to