-
Notifications
You must be signed in to change notification settings - Fork 25.2k
[Transform] correctly retrieve checkpoints from remote indices #50903
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
[Transform] correctly retrieve checkpoints from remote indices #50903
Conversation
Pinging @elastic/ml-core (:ml/Transform) |
return localIndices; | ||
} | ||
|
||
public int size() { |
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.
public int size() { | |
public int numClusters() { |
Or something. I thought size()
was meant to be the number of total resolved indices, but instead it is used to help allocate the grouped listener.
client, | ||
transformConfig.getHeaders(), | ||
resolvedIndexes.getLocalIndices().toArray(new String[0]), | ||
"", |
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.
"", | |
LOCAL_CLUSTER_GROUP_KEY, |
run elasticsearch-ci/bwc |
run elasticsearch-ci/bwc |
c109593
to
4cf7691
Compare
…ic#50903) uses remote client(s) to correctly retrieve index checkpoints from remote clusters
…ic#50903) uses remote client(s) to correctly retrieve index checkpoints from remote clusters
uses remote client(s) to correctly retrieve index checkpoints from remote clusters