You are viewing a plain text version of this content. The canonical link for it is here.

Posted to github@beam.apache.org by "kennknowles (via GitHub)" <gi...@apache.org> on 2023/05/03 18:01:23 UTC

[GitHub] [beam] kennknowles commented on issue #26041: [Bug]: Unable to create exactly-once Flink pipeline with stream source and file sink

kennknowles commented on issue #26041:
URL: https://github.com/apache/beam/issues/26041#issuecomment-1533481717

   I wonder if this has to do with `RequiresStableInput`. I do know that there are places where it is required for randomly generated UUIDs to be checkpointed and replayed deterministically. I don't know enough about Flink or the FlinkRunner to know why restarting from checkpoint would be different from an app restart. I also don't know enough to know if this is more general to the IO connector.


-- 
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: github-unsubscribe@beam.apache.org

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