-
-
Notifications
You must be signed in to change notification settings - Fork 98
Properly handle partition_transformer
shutdown
#5301
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
Conversation
📚 Documentation Preview🧹 Preview deployment has been cleaned up The documentation preview for this PR has been removed since the PR was closed. |
cc6f0f2
to
9f8cba4
Compare
partition_transformer
` shutdownpartition_transformer
shutdown
9f8cba4
to
1bedfb2
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Pull Request Overview
This PR improves the shutdown process for partition transformers by adding monitoring and active management of those actors, ensuring a graceful and parallel shutdown to avoid hangs.
- Adds registration and monitoring of partition_transformer actors in the index state.
- Implements a new shutdown procedure that disposes monitors and shuts down all active transformers.
- Updates the changelog to document the shutdown hang fix.
Reviewed Changes
Copilot reviewed 3 out of 3 changed files in this pull request and generated no comments.
File | Description |
---|---|
libtenzir/src/index.cpp | Introduces monitoring and parallel shutdown for partition transformers. |
libtenzir/include/tenzir/index.hpp | Adds active_transformers map with detailed documentation for transformer actors. |
changelog/changes/centre-backed-agree.md | Documents the bugfix for the shutdown hang in partition rebuild scenarios. |
Comments suppressed due to low confidence (1)
libtenzir/src/index.cpp:1560
- The variable 'partition_transfomer' appears to be misspelled; consider renaming it to 'partition_transformer' for clarity.
std::move(partition_synopsis_path_template));
The index actor keeps track of all currently running `partition_transformer`s and properly shuts them down.
1bedfb2
to
8976f8b
Compare
The index actor keeps track of all currently running
partition_transformer
s and properly shuts them down.