Xeli commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-464767127 @rmetzger Ah sorry, I missed those other questions because of the GitHub UI indeed :) I'll go over all questions today. Regarding the message pulling proposal. I agree with you, the model you describe is a lot cleaner and I initially tried it implementing it that way. However, because this PR started back in June I cannot remember why I moved away from sync to async API... I'm willing to give the sync API a try again, but I fear we won't be able to test it enough before the feature freeze of 1.8. Are you able to help testing the stability on actual Flink clusters with Pubsub this week if I switch to the sync API? And do you think it will be feasible to get this stable before 1.8?
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
