ppawel commented on issue #20219: URL: https://github.com/apache/beam/issues/20219#issuecomment-1531557624
I have a commit in my branch that potentially fixes this issue but I'm not 100% sure if it's the correct way. See https://github.com/ppawel/beam/commit/5eaa8f44a117171afc25a920e868de22f7d212b8 I basically tried following what `JdbcIO` is doing, as it has been suggested in the original Jira issue. I am using a custom build of Beam 2.48 with this commit with a Google Dataflow runner and it seems to work fine, meaning that I am able to use `Wait.on` the output of Datastore write transform and it does indeed wait until writing is done. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
