lvyanquan commented on PR #3646:
URL: https://github.com/apache/flink-cdc/pull/3646#issuecomment-2416311635

   I think a test for this is still necessary. 
   We have two bound sources(values, MySQL when setting scan.startup.mode to 
snapshot), and I don't get the point that you said "the sink never receives the 
end-of-input signal", can you provide a more detailed description? we can add 
some logs in flush method if endOfInput is true to verify this.
   


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

To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to