Correct arg names when update mapping/settings from leader (#38063)

These two arguments are not named incorrectly and caused confusion.
This commit is contained in:
Nhat Nguyen 2019-01-31 02:45:42 -05:00 committed by GitHub
parent a8596de31f
commit 1a93976ff7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions

View File

@ -133,21 +133,21 @@ public abstract class ShardFollowNodeTask extends AllocatedPersistentTask {
}
// updates follower mapping, this gets us the leader mapping version and makes sure that leader and follower mapping are identical
updateMapping(0L, followerMappingVersion -> {
updateMapping(0L, leaderMappingVersion -> {
synchronized (ShardFollowNodeTask.this) {
currentMappingVersion = followerMappingVersion;
currentMappingVersion = leaderMappingVersion;
}
updateSettings(followerSettingsVersion -> {
updateSettings(leaderSettingsVersion -> {
synchronized (ShardFollowNodeTask.this) {
currentSettingsVersion = followerSettingsVersion;
currentSettingsVersion = leaderSettingsVersion;
}
LOGGER.info(
"{} following leader shard {}, follower global checkpoint=[{}], mapping version=[{}], settings version=[{}]",
params.getFollowShardId(),
params.getLeaderShardId(),
followerGlobalCheckpoint,
followerMappingVersion,
followerSettingsVersion);
leaderMappingVersion,
leaderSettingsVersion);
coordinateReads();
});
});