-
Notifications
You must be signed in to change notification settings - Fork 25k
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
Zen2: Add diff-based publishing #35290
Conversation
Pinging @elastic/es-distributed |
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.
I left one question. I also think there should perhaps be a few more tests in PublicationTransportHandlerTests
showing its behaviour in isolation, although I'm not convinced of this since the coverage through CoordinatorTests
is good.
final DiscoveryNodes nodes = clusterChangedEvent.state().nodes(); | ||
final ClusterState newState = clusterChangedEvent.state(); | ||
final ClusterState previousState = clusterChangedEvent.previousState(); | ||
final boolean sendFullVersion = clusterChangedEvent.previousState().getBlocks().disableStatePersistence(); |
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.
Should we also obey discovery.zen.publish_diff.enable
here?
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.
I would like to avoid exposing this as a setting and having this configurable in Zen2, which is why I deliberately opted not to implement this.
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.
LGTM
Enables diff-based publishing, which is an optimization where only the changing parts of the cluster state are published to the nodes in the cluster, falling back to full cluster state publishing if the receiver does not have the previous cluster state.