Skip to content

[Dataflow Streaming] Invalidate caches and remove work on failure before commit#30229

Merged
scwhittle merged 2 commits intoapache:masterfrom
arunpandianp:fixFailedWork
Feb 6, 2024
Merged

[Dataflow Streaming] Invalidate caches and remove work on failure before commit#30229
scwhittle merged 2 commits intoapache:masterfrom
arunpandianp:fixFailedWork

Conversation

@arunpandianp
Copy link
Copy Markdown
Contributor

No description provided.

@arunpandianp
Copy link
Copy Markdown
Contributor Author

R: @scwhittle

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Feb 6, 2024

Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control

@arunpandianp
Copy link
Copy Markdown
Contributor Author

This is same as #30215, with logic to catch any exceptions thrown by completeWorkAndScheduleNextWorkForKey on the commit thread.

@arunpandianp
Copy link
Copy Markdown
Contributor Author

Modified completeWorkAndScheduleNextWorkForKey to not throw.

@scwhittle scwhittle merged commit 5494f11 into apache:master Feb 6, 2024
lostluck added a commit that referenced this pull request Feb 6, 2024
… work on failure before commit (#30234)

* Invalidate caches and remove work on failure before commit

* Prevent completeWorkAndScheduleNextWorkForKey from throwing

---------

Co-authored-by: Arun Pandian <pandiana@google.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants