Skip to content

Delay task execution in MetadataUpdateSettingsService until reroute is complete#88783

Merged
idegtiarenko merged 1 commit intoelastic:feature/desired-balance-allocatorfrom
idegtiarenko:delay_update_settings_listeners
Jul 26, 2022
Merged

Delay task execution in MetadataUpdateSettingsService until reroute is complete#88783
idegtiarenko merged 1 commit intoelastic:feature/desired-balance-allocatorfrom
idegtiarenko:delay_update_settings_listeners

Conversation

@idegtiarenko
Copy link
Copy Markdown
Contributor

No description provided.

@idegtiarenko idegtiarenko added :Distributed/Allocation All issues relating to the decision making around placing a shard (both master logic & on the nodes) Team:Distributed Meta label for distributed team. labels Jul 25, 2022
@idegtiarenko idegtiarenko requested a review from DaveCTurner July 25, 2022 18:01
public boolean mustAck(DiscoveryNode discoveryNode) {
return true;
}
private ClusterStateAckListener getAckListener(AllocationActionMultiListener<AcknowledgedResponse> multiListener) {
Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@DaveCTurner I believe we discussed this here: #88643 (comment)

However I am not sure if there is a better way to wrap/delay the listener as it is final and task is created before executor and before AllocationActionMultiListener is available.

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Makes sense in this context 👍

@idegtiarenko idegtiarenko marked this pull request as ready for review July 26, 2022 06:24
@elasticsearchmachine
Copy link
Copy Markdown
Collaborator

Pinging @elastic/es-distributed (Team:Distributed)

Copy link
Copy Markdown
Member

@DaveCTurner DaveCTurner left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

public boolean mustAck(DiscoveryNode discoveryNode) {
return true;
}
private ClusterStateAckListener getAckListener(AllocationActionMultiListener<AcknowledgedResponse> multiListener) {
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Makes sense in this context 👍

@idegtiarenko idegtiarenko merged commit 8459336 into elastic:feature/desired-balance-allocator Jul 26, 2022
@idegtiarenko idegtiarenko deleted the delay_update_settings_listeners branch July 26, 2022 12:01
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

:Distributed/Allocation All issues relating to the decision making around placing a shard (both master logic & on the nodes) Team:Distributed Meta label for distributed team.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants