diff --git a/src/java/org/apache/cassandra/io/Streaming.java b/src/java/org/apache/cassandra/io/Streaming.java index ec04986102..2dd60da38f 100644 --- a/src/java/org/apache/cassandra/io/Streaming.java +++ b/src/java/org/apache/cassandra/io/Streaming.java @@ -112,15 +112,13 @@ public class Streaming if (streamContexts.length > 0) { - if (logger.isDebugEnabled()) - logger.debug("Waiting for transfer to " + target + " to complete"); + logger.info("Waiting for transfer to " + target + " to complete"); StreamManager.instance(target).waitForStreamCompletion(); for (SSTableReader sstable : sstables) { sstable.markCompacted(); } - if (logger.isDebugEnabled()) - logger.debug("Done with transfer to " + target); + logger.info("Done with transfer to " + target); } } diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index 7d6a8a33d5..181a882981 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -180,7 +180,7 @@ public final class StorageService implements IEndPointStateChangeSubscriber, Sto SystemTable.setBootstrapped(true); setToken(getLocalToken()); Gossiper.instance().addApplicationState(StorageService.STATE_NORMAL, new ApplicationState(partitioner_.getTokenFactory().toString(getLocalToken()))); - logger_.info("Bootstrap completed! Now serving reads."); + logger_.info("Bootstrap/move completed! Now serving reads."); } /** This method updates the local token on disk */