diff --git a/src/java/org/apache/cassandra/locator/TokenMetadata.java b/src/java/org/apache/cassandra/locator/TokenMetadata.java index 099f439658..0c69018227 100644 --- a/src/java/org/apache/cassandra/locator/TokenMetadata.java +++ b/src/java/org/apache/cassandra/locator/TokenMetadata.java @@ -968,14 +968,14 @@ private PendingRangeMaps calculatePendingRanges(AbstractReplicationStrategy stra { Collection tokens = bootstrapAddresses.get(endpoint); allLeftMetadata.updateNormalTokens(tokens, endpoint); - Collection> addressRangesForEndpoint = strategy.getAddressRanges(allLeftMetadata).get(endpoint); - for (Range range : addressRangesForEndpoint) + Collection> tokenRangeForEndpoint = strategy.getAddressRanges(allLeftMetadata).get(endpoint); + for (Range range : tokenRangeForEndpoint) { newPendingRanges.addPendingRange(range, endpoint); } allLeftMetadata.removeEndpoint(endpoint); - logBootstrapDifference(endpoint, addressRangesSnapshot, addressRangesForEndpoint); + logBootstrapDifference(strategy.keyspaceName, endpoint, addressRangesSnapshot, tokenRangeForEndpoint); } // At this stage newPendingRanges has been updated according to leaving and bootstrapping nodes. @@ -1385,16 +1385,16 @@ private void logLeavingEndpointDifference(String keyspace, Set leav } } - private void logBootstrapDifference(String keyspace, InetAddress endpoint, Multimap, InetAddress> snapshot, Collection> newTokenRanges) + private void logBootstrapDifference(String keyspace, InetAddress endpoint, Multimap, InetAddress> snapshot, Collection> tokenRangeForEndpoint) { if (shouldLogTokenChanges) { logger.info("Pending ranges for bootstrapping endpoint", SafeArg.of("keyspace", keyspace), SafeArg.of("bootstrapingEndpoint", endpoint), - SafeArg.of("previousOwners", MapUtils.intersection(snapshot, newTokenRanges)), - SafeArg.of("pendingRangeCount", newTokenRanges.size())); - logger.debug("Pending range for endpoint", newTokenRanges); + SafeArg.of("previousOwners", MapUtils.intersection(snapshot, tokenRangeForEndpoint)), + SafeArg.of("pendingRangeCount", tokenRangeForEndpoint.size())); + logger.debug("Pending range for endpoint", SafeArg.of("pendingRange", tokenRangeForEndpoint)); } }