-
Notifications
You must be signed in to change notification settings - Fork 59
feat(bulk-load): bulk load succeed part2 - meta handle bulk load succeed #508
Conversation
|
||
bool group_cleaned_up = response.is_group_bulk_load_context_cleaned_up; | ||
ddebug_f("receive bulk load response from node({}) app({}) partition({}), primary status = {}, " | ||
"is_group_bulk_load_context_cleaned_up = {}", |
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.
Please tell a meaningful message in the log so that we can learn what "is_group_bulk_load_context_cleaned_up" means.
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.
Why the replica group will succeed without their states cleared?
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.
when partition finish ingesting, its status will turn ingesting -> succeed, meta will still send bulk_load_request
to replica, replica will turn ingesting -> succeed and cleanup its bulk load context, replica status should be invalid when it clean up bulk load status not succeed.
|
||
bool group_cleaned_up = response.is_group_bulk_load_context_cleaned_up; | ||
ddebug_f("receive bulk load response from node({}) app({}) partition({}), primary status = {}, " | ||
"is_group_bulk_load_context_cleaned_up = {}", |
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.
Why the replica group will succeed without their states cleared?
The whole bulk load succeed process is like:
This pull request is about meta handle bulk load succeed, step 8 above.
meta handle bulk_load_response in
handle_bulk_load_finish
_partitions_cleaned_up[pid] = true
and_apps_in_progress_count[app_id] - 1
remove_bulk_load_dir_on_remote_storage
), reset local bulk load states(in functionreset_local_bulk_load_states
), set app's is_bulk_loading as false (in functionupdate_app_not_bulk_loading_on_remote_storage
), whole bulk load process finishedTips:
when app's is_bulk_loading = false, meta will not send bulk load request to replica server any more in function
try_resend_bulk_load_request
#463