diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowNodeTask.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowNodeTask.java index 233085c0a6857..a4f02707bc40f 100644 --- a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowNodeTask.java +++ b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowNodeTask.java @@ -133,21 +133,21 @@ void start( } // 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(); }); });