Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

PubSub Sink Task Flush issues with clearing partition tracking. #307

Open
jordanbull opened this issue Dec 27, 2021 · 0 comments
Open

PubSub Sink Task Flush issues with clearing partition tracking. #307

jordanbull opened this issue Dec 27, 2021 · 0 comments

Comments

@jordanbull
Copy link
Contributor

The current behavior will throw after reaching the first exception and only clears that partition in the finally block. This results in subsequent partitions not being cleared of tracking and potentially just throwing in the subsequent commit calls.

It also clears tracking for all partitions even if they are not in the list of partitions to flush.

#306 should fix these two issues.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant