You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by db...@apache.org on 2013/10/22 02:07:57 UTC
git commit: use parameterized logging
Updated Branches:
refs/heads/trunk e4a21b059 -> db9bc6929
use parameterized logging
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/db9bc692
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/db9bc692
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/db9bc692
Branch: refs/heads/trunk
Commit: db9bc6929657fac40cf25af94bf919f1b213655a
Parents: e4a21b0
Author: Dave Brosius <db...@mebigfatguy.com>
Authored: Mon Oct 21 20:06:30 2013 -0400
Committer: Dave Brosius <db...@mebigfatguy.com>
Committed: Mon Oct 21 20:06:30 2013 -0400
----------------------------------------------------------------------
.../org/apache/cassandra/client/RingCache.java | 2 +-
.../db/commitlog/CommitLogReplayer.java | 3 +-
.../cassandra/db/compaction/Scrubber.java | 2 +-
.../hadoop/AbstractColumnFamilyInputFormat.java | 6 +-
.../cassandra/hadoop/BulkRecordWriter.java | 2 +-
.../hadoop/ColumnFamilyRecordReader.java | 2 +-
.../cassandra/hadoop/cql3/CqlRecordWriter.java | 4 +-
.../apache/cassandra/io/sstable/SSTable.java | 2 +-
.../io/sstable/SSTableDeletingTask.java | 2 +-
.../cassandra/io/sstable/SSTableReader.java | 12 ++--
.../org/apache/cassandra/io/util/FileUtils.java | 6 +-
.../cassandra/locator/Ec2MultiRegionSnitch.java | 2 +-
.../org/apache/cassandra/locator/Ec2Snitch.java | 2 +-
.../locator/GossipingPropertyFileSnitch.java | 4 +-
.../cassandra/locator/PropertyFileSnitch.java | 2 +-
.../cassandra/locator/SimpleSeedProvider.java | 2 +-
.../cassandra/locator/SnitchProperties.java | 2 +-
.../apache/cassandra/locator/TokenMetadata.java | 2 +-
.../apache/cassandra/net/MessagingService.java | 2 +-
.../cassandra/net/OutboundTcpConnection.java | 6 +-
.../apache/cassandra/repair/Differencer.java | 2 +-
.../apache/cassandra/repair/RepairSession.java | 4 +-
.../org/apache/cassandra/repair/Validator.java | 8 +--
.../cassandra/service/CassandraDaemon.java | 10 +--
.../cassandra/service/MigrationManager.java | 2 +-
.../cassandra/service/RowDataResolver.java | 2 +-
.../cassandra/service/RowDigestResolver.java | 2 +-
.../cassandra/service/StorageService.java | 70 ++++++++++----------
.../cassandra/streaming/ConnectionHandler.java | 2 +-
.../ReplicationFinishedVerbHandler.java | 2 +-
.../cassandra/streaming/StreamSession.java | 4 +-
.../cassandra/thrift/CassandraServer.java | 2 +-
.../thrift/CustomTThreadPoolServer.java | 2 +-
.../cassandra/thrift/ThriftValidation.java | 2 +-
.../org/apache/cassandra/utils/CLibrary.java | 4 +-
35 files changed, 92 insertions(+), 93 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/client/RingCache.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/client/RingCache.java b/src/java/org/apache/cassandra/client/RingCache.java
index 3308471..9b04518 100644
--- a/src/java/org/apache/cassandra/client/RingCache.java
+++ b/src/java/org/apache/cassandra/client/RingCache.java
@@ -96,7 +96,7 @@ public class RingCache
}
catch (TException e)
{
- logger.debug("Error contacting seed list" + ConfigHelper.getOutputInitialAddress(conf) + " " + e.getMessage());
+ logger.debug("Error contacting seed list {} {}", ConfigHelper.getOutputInitialAddress(conf), e.getMessage());
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java b/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java
index d0088c1..532736b 100644
--- a/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java
+++ b/src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java
@@ -239,8 +239,7 @@ public class CommitLogReplayer
}
if (logger.isDebugEnabled())
- logger.debug(String.format("replaying mutation for %s.%s: %s", rm.getKeyspaceName(), ByteBufferUtil.bytesToHex(rm.key()), "{" + StringUtils.join(rm.getColumnFamilies().iterator(), ", ")
- + "}"));
+ logger.debug("replaying mutation for {}.{}: {}", rm.getKeyspaceName(), ByteBufferUtil.bytesToHex(rm.key()), "{" + StringUtils.join(rm.getColumnFamilies().iterator(), ", ") + "}");
final long entryLocation = reader.getFilePointer();
final RowMutation frm = rm;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/db/compaction/Scrubber.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/Scrubber.java b/src/java/org/apache/cassandra/db/compaction/Scrubber.java
index d8a2745..e435c24 100644
--- a/src/java/org/apache/cassandra/db/compaction/Scrubber.java
+++ b/src/java/org/apache/cassandra/db/compaction/Scrubber.java
@@ -120,7 +120,7 @@ public class Scrubber implements Closeable
if (scrubInfo.isStopRequested())
throw new CompactionInterruptedException(scrubInfo.getCompactionInfo());
long rowStart = dataFile.getFilePointer();
- outputHandler.debug("Reading row at " + rowStart);
+ outputHandler.debug("Reading row at {}" + rowStart);
DecoratedKey key = null;
long dataSize = -1;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java b/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java
index 060469d..c7a3187 100644
--- a/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java
+++ b/src/java/org/apache/cassandra/hadoop/AbstractColumnFamilyInputFormat.java
@@ -123,7 +123,7 @@ public abstract class AbstractColumnFamilyInputFormat<K, Y> extends InputFormat<
keyspace = ConfigHelper.getInputKeyspace(context.getConfiguration());
cfName = ConfigHelper.getInputColumnFamily(context.getConfiguration());
partitioner = ConfigHelper.getInputPartitioner(context.getConfiguration());
- logger.debug("partitioner is " + partitioner);
+ logger.debug("partitioner is {}", partitioner);
// cannonical ranges, split into pieces, fetching the splits in parallel
ExecutorService executor = new ThreadPoolExecutor(0, 128, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
@@ -252,7 +252,7 @@ public abstract class AbstractColumnFamilyInputFormat<K, Y> extends InputFormat<
subSplit.getRow_count(),
endpoints);
- logger.debug("adding " + split);
+ logger.debug("adding {}", split);
splits.add(split);
}
}
@@ -292,7 +292,7 @@ public abstract class AbstractColumnFamilyInputFormat<K, Y> extends InputFormat<
}
catch (IOException e)
{
- logger.debug("failed connect to endpoint " + host, e);
+ logger.debug("failed connect to endpoint {}", host, e);
}
catch (InvalidRequestException e)
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java b/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
index b6a7e75..f761a8c 100644
--- a/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/BulkRecordWriter.java
@@ -247,7 +247,7 @@ implements org.apache.hadoop.mapred.RecordWriter<ByteBuffer,List<Mutation>>
if (loader.getFailedHosts().size() > maxFailures)
throw new IOException("Too many hosts failed: " + loader.getFailedHosts());
else
- logger.warn("Some hosts failed: " + loader.getFailedHosts());
+ logger.warn("Some hosts failed: {}", loader.getFailedHosts());
}
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
index e33aea9..98a294d 100644
--- a/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
+++ b/src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java
@@ -174,7 +174,7 @@ public class ColumnFamilyRecordReader extends RecordReader<ByteBuffer, SortedMap
{
if (!iter.hasNext())
{
- logger.debug("Finished scanning " + iter.rowsRead() + " rows (estimate was: " + totalRowCount + ")");
+ logger.debug("Finished scanning {} rows (estimate was: {})", iter.rowsRead(), totalRowCount);
return false;
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
index 4746f8a..27d1c70 100644
--- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
+++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordWriter.java
@@ -334,7 +334,7 @@ final class CqlRecordWriter extends AbstractColumnFamilyRecordWriter<Map<String,
Column rawPartitionKeys = result.rows.get(0).columns.get(1);
String keyString = ByteBufferUtil.string(ByteBuffer.wrap(rawPartitionKeys.getValue()));
- logger.debug("partition keys: " + keyString);
+ logger.debug("partition keys: {}", keyString);
List<String> keys = FBUtilities.fromJsonList(keyString);
partitionKeyColumns = new String[keys.size()];
@@ -348,7 +348,7 @@ final class CqlRecordWriter extends AbstractColumnFamilyRecordWriter<Map<String,
Column rawClusterColumns = result.rows.get(0).columns.get(2);
String clusterColumnString = ByteBufferUtil.string(ByteBuffer.wrap(rawClusterColumns.getValue()));
- logger.debug("cluster columns: " + clusterColumnString);
+ logger.debug("cluster columns: {}", clusterColumnString);
clusterColumns = FBUtilities.fromJsonList(clusterColumnString);
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/io/sstable/SSTable.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTable.java b/src/java/org/apache/cassandra/io/sstable/SSTable.java
index eaa4522..e469b33 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTable.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTable.java
@@ -303,7 +303,7 @@ public abstract class SSTable
{
Component component = new Component(Component.Type.fromRepresentation(componentName), componentName);
if (!new File(descriptor.filenameFor(component)).exists())
- logger.error("Missing component: " + descriptor.filenameFor(component));
+ logger.error("Missing component: {}", descriptor.filenameFor(component));
else
components.add(component);
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/io/sstable/SSTableDeletingTask.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTableDeletingTask.java b/src/java/org/apache/cassandra/io/sstable/SSTableDeletingTask.java
index fb7f036..bdc6c65 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTableDeletingTask.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTableDeletingTask.java
@@ -78,7 +78,7 @@ public class SSTableDeletingTask implements Runnable
File datafile = new File(desc.filenameFor(Component.DATA));
if (!datafile.delete())
{
- logger.error("Unable to delete " + datafile + " (it will be removed on server restart; we'll also retry after GC)");
+ logger.error("Unable to delete {} (it will be removed on server restart; we'll also retry after GC)", datafile);
failedTasks.add(this);
return;
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/io/sstable/SSTableReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/sstable/SSTableReader.java b/src/java/org/apache/cassandra/io/sstable/SSTableReader.java
index cb0873d..9b2edb0 100644
--- a/src/java/org/apache/cassandra/io/sstable/SSTableReader.java
+++ b/src/java/org/apache/cassandra/io/sstable/SSTableReader.java
@@ -117,7 +117,7 @@ public class SSTableReader extends SSTable implements Closeable
int indexKeyCount = sstable.getKeySampleSize();
count = count + (indexKeyCount + 1) * sstable.indexSummary.getIndexInterval();
if (logger.isDebugEnabled())
- logger.debug("index size for bloom filter calc for file : " + sstable.getFilename() + " : " + count);
+ logger.debug("index size for bloom filter calc for file : {} : {}", sstable.getFilename(), count);
}
return count;
@@ -239,9 +239,9 @@ public class SSTableReader extends SSTable implements Closeable
public static void logOpenException(Descriptor descriptor, IOException e)
{
if (e instanceof FileNotFoundException)
- logger.error("Missing sstable component in " + descriptor + "; skipped because of " + e.getMessage());
+ logger.error("Missing sstable component in {}; skipped because of {}", descriptor, e.getMessage());
else
- logger.error("Corrupt sstable " + descriptor + "; skipped", e);
+ logger.error("Corrupt sstable {}; skipped", descriptor, e);
}
public static Collection<SSTableReader> openAll(Set<Map.Entry<Descriptor, Set<Component>>> entries,
@@ -264,7 +264,7 @@ public class SSTableReader extends SSTable implements Closeable
}
catch (IOException ex)
{
- logger.error("Corrupt sstable " + entry + "; skipped", ex);
+ logger.error("Corrupt sstable {}; skipped", entry, ex);
return;
}
sstables.add(sstable);
@@ -1108,7 +1108,7 @@ public class SSTableReader extends SSTable implements Closeable
public boolean markObsolete()
{
if (logger.isDebugEnabled())
- logger.debug("Marking " + getFilename() + " compacted");
+ logger.debug("Marking {} compacted", getFilename());
return !isCompacted.getAndSet(true);
}
@@ -1116,7 +1116,7 @@ public class SSTableReader extends SSTable implements Closeable
public void markSuspect()
{
if (logger.isDebugEnabled())
- logger.debug("Marking " + getFilename() + " as a suspect for blacklisting.");
+ logger.debug("Marking {} as a suspect for blacklisting.", getFilename());
isSuspect.getAndSet(true);
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/io/util/FileUtils.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/io/util/FileUtils.java b/src/java/org/apache/cassandra/io/util/FileUtils.java
index 6b91bd3..3c84cc3 100644
--- a/src/java/org/apache/cassandra/io/util/FileUtils.java
+++ b/src/java/org/apache/cassandra/io/util/FileUtils.java
@@ -110,7 +110,7 @@ public class FileUtils
{
assert file.exists() : "attempted to delete non-existing file " + file.getName();
if (logger.isDebugEnabled())
- logger.debug("Deleting " + file.getName());
+ logger.debug("Deleting {}", file.getName());
try
{
Files.delete(file.toPath());
@@ -211,7 +211,7 @@ public class FileUtils
}
catch (Exception e)
{
- logger.warn("Failed closing " + c, e);
+ logger.warn("Failed closing {}", c, e);
}
}
@@ -233,7 +233,7 @@ public class FileUtils
catch (IOException ex)
{
e = ex;
- logger.warn("Failed closing stream " + c, ex);
+ logger.warn("Failed closing stream {}", c, ex);
}
}
if (e != null)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/locator/Ec2MultiRegionSnitch.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/Ec2MultiRegionSnitch.java b/src/java/org/apache/cassandra/locator/Ec2MultiRegionSnitch.java
index bd5e091..7dc2fa9 100644
--- a/src/java/org/apache/cassandra/locator/Ec2MultiRegionSnitch.java
+++ b/src/java/org/apache/cassandra/locator/Ec2MultiRegionSnitch.java
@@ -48,7 +48,7 @@ public class Ec2MultiRegionSnitch extends Ec2Snitch
{
super();
localPublicAddress = InetAddress.getByName(awsApiCall(PUBLIC_IP_QUERY_URL));
- logger.info("EC2Snitch using publicIP as identifier: " + localPublicAddress);
+ logger.info("EC2Snitch using publicIP as identifier: {}", localPublicAddress);
localPrivateAddress = awsApiCall(PRIVATE_IP_QUERY_URL);
// use the Public IP to broadcast Address to other nodes.
DatabaseDescriptor.setBroadcastAddress(localPublicAddress);
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/locator/Ec2Snitch.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/Ec2Snitch.java b/src/java/org/apache/cassandra/locator/Ec2Snitch.java
index 37301c1..8d3313f 100644
--- a/src/java/org/apache/cassandra/locator/Ec2Snitch.java
+++ b/src/java/org/apache/cassandra/locator/Ec2Snitch.java
@@ -65,7 +65,7 @@ public class Ec2Snitch extends AbstractNetworkTopologySnitch
String datacenterSuffix = SnitchProperties.get("dc_suffix", "");
ec2region = ec2region.concat(datacenterSuffix);
- logger.info("EC2Snitch using region: " + ec2region + ", zone: " + ec2zone + ".");
+ logger.info("EC2Snitch using region: {}, zone: {}.", ec2region, ec2zone);
}
String awsApiCall(String url) throws IOException, ConfigurationException
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/locator/GossipingPropertyFileSnitch.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/GossipingPropertyFileSnitch.java b/src/java/org/apache/cassandra/locator/GossipingPropertyFileSnitch.java
index dd1637d..83c1efe 100644
--- a/src/java/org/apache/cassandra/locator/GossipingPropertyFileSnitch.java
+++ b/src/java/org/apache/cassandra/locator/GossipingPropertyFileSnitch.java
@@ -58,11 +58,11 @@ public class GossipingPropertyFileSnitch extends AbstractNetworkTopologySnitch//
try
{
psnitch = new PropertyFileSnitch();
- logger.info("Loaded " + PropertyFileSnitch.SNITCH_PROPERTIES_FILENAME + " for compatibility");
+ logger.info("Loaded {} for compatibility", PropertyFileSnitch.SNITCH_PROPERTIES_FILENAME);
}
catch (ConfigurationException e)
{
- logger.info("Unable to load " + PropertyFileSnitch.SNITCH_PROPERTIES_FILENAME + "; compatibility mode disabled");
+ logger.info("Unable to load {}; compatibility mode disabled", PropertyFileSnitch.SNITCH_PROPERTIES_FILENAME);
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/locator/PropertyFileSnitch.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/PropertyFileSnitch.java b/src/java/org/apache/cassandra/locator/PropertyFileSnitch.java
index da440af..e75dcbb 100644
--- a/src/java/org/apache/cassandra/locator/PropertyFileSnitch.java
+++ b/src/java/org/apache/cassandra/locator/PropertyFileSnitch.java
@@ -73,7 +73,7 @@ public class PropertyFileSnitch extends AbstractNetworkTopologySnitch
}
catch (ConfigurationException ex)
{
- logger.debug(SNITCH_PROPERTIES_FILENAME + " found, but does not look like a plain file. Will not watch it for changes");
+ logger.debug("{} found, but does not look like a plain file. Will not watch it for changes", SNITCH_PROPERTIES_FILENAME);
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/locator/SimpleSeedProvider.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/SimpleSeedProvider.java b/src/java/org/apache/cassandra/locator/SimpleSeedProvider.java
index a3031fa..90309bc 100644
--- a/src/java/org/apache/cassandra/locator/SimpleSeedProvider.java
+++ b/src/java/org/apache/cassandra/locator/SimpleSeedProvider.java
@@ -46,7 +46,7 @@ public class SimpleSeedProvider implements SeedProvider
catch (UnknownHostException ex)
{
// not fatal... DD will bark if there end up being zero seeds.
- logger.warn("Seed provider couldn't lookup host " + host);
+ logger.warn("Seed provider couldn't lookup host {}", host);
}
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/locator/SnitchProperties.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/SnitchProperties.java b/src/java/org/apache/cassandra/locator/SnitchProperties.java
index 809a180..a8b2d03 100644
--- a/src/java/org/apache/cassandra/locator/SnitchProperties.java
+++ b/src/java/org/apache/cassandra/locator/SnitchProperties.java
@@ -40,7 +40,7 @@ public class SnitchProperties
catch (Exception e)
{
// do not throw exception here, just consider this a incomplete or a empty property file.
- logger.warn("Unable to read " + RACKDC_PROPERTY_FILENAME);
+ logger.warn("Unable to read {}", RACKDC_PROPERTY_FILENAME);
}
finally
{
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/locator/TokenMetadata.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/TokenMetadata.java b/src/java/org/apache/cassandra/locator/TokenMetadata.java
index addd662..f6eb520 100644
--- a/src/java/org/apache/cassandra/locator/TokenMetadata.java
+++ b/src/java/org/apache/cassandra/locator/TokenMetadata.java
@@ -198,7 +198,7 @@ public class TokenMetadata
if (!endpoint.equals(prev))
{
if (prev != null)
- logger.warn("Token " + token + " changing ownership from " + prev + " to " + endpoint);
+ logger.warn("Token {} changing ownership from {} to {}", token, prev, endpoint);
shouldSortTokens = true;
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/net/MessagingService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/net/MessagingService.java b/src/java/org/apache/cassandra/net/MessagingService.java
index 145919d..23dad0a 100644
--- a/src/java/org/apache/cassandra/net/MessagingService.java
+++ b/src/java/org/apache/cassandra/net/MessagingService.java
@@ -393,7 +393,7 @@ public final class MessagingService implements MessagingServiceMBean
*/
public void convict(InetAddress ep)
{
- logger.debug("Resetting pool for " + ep);
+ logger.debug("Resetting pool for {}", ep);
getConnectionPool(ep).reset();
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
index d5c64b9..3bdbca3 100644
--- a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
+++ b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
@@ -219,7 +219,7 @@ public class OutboundTcpConnection extends Thread
if (e instanceof IOException)
{
if (logger.isDebugEnabled())
- logger.debug("error writing to " + poolReference.endPoint(), e);
+ logger.debug("error writing to {}", poolReference.endPoint(), e);
// if the message was important, such as a repair acknowledgement, put it back on the queue
// to retry after re-connecting. See CASSANDRA-5393
@@ -238,7 +238,7 @@ public class OutboundTcpConnection extends Thread
else
{
// Non IO exceptions are likely a programming error so let's not silence them
- logger.error("error writing to " + poolReference.endPoint(), e);
+ logger.error("error writing to {}", poolReference.endPoint(), e);
}
}
}
@@ -294,7 +294,7 @@ public class OutboundTcpConnection extends Thread
private boolean connect()
{
if (logger.isDebugEnabled())
- logger.debug("attempting to connect to " + poolReference.endPoint());
+ logger.debug("attempting to connect to {}", poolReference.endPoint());
long start = System.nanoTime();
long timeout = TimeUnit.MILLISECONDS.toNanos(DatabaseDescriptor.getRpcTimeout());
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/repair/Differencer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/repair/Differencer.java b/src/java/org/apache/cassandra/repair/Differencer.java
index 214d2c9..470c1ae 100644
--- a/src/java/org/apache/cassandra/repair/Differencer.java
+++ b/src/java/org/apache/cassandra/repair/Differencer.java
@@ -71,7 +71,7 @@ public class Differencer implements Runnable
}
// non-0 difference: perform streaming repair
- logger.info(String.format(format, "have " + differences.size() + " range(s) out of sync"));
+ logger.info(format, "have {} range(s) out of sync", differences.size());
performStreamingRepair();
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/repair/RepairSession.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/repair/RepairSession.java b/src/java/org/apache/cassandra/repair/RepairSession.java
index 2e93104..91c31d6 100644
--- a/src/java/org/apache/cassandra/repair/RepairSession.java
+++ b/src/java/org/apache/cassandra/repair/RepairSession.java
@@ -159,7 +159,7 @@ public class RepairSession extends WrappedRunnable implements IEndpointStateChan
assert job.desc.equals(desc);
if (job.addTree(endpoint, tree) == 0)
{
- logger.debug("All response received for " + getId() + "/" + desc.columnFamily);
+ logger.debug("All response received for {}/{}", getId(), desc.columnFamily);
if (!job.isFailed())
{
syncingJobs.put(job.desc.columnFamily, job);
@@ -249,7 +249,7 @@ public class RepairSession extends WrappedRunnable implements IEndpointStateChan
{
String message = String.format("Cannot proceed on repair because a neighbor (%s) is dead: session failed", endpoint);
differencingDone.signalAll();
- logger.error(String.format("[repair #%s] ", getId()) + message);
+ logger.error("[repair #{}] {}", getId(), message);
throw new IOException(message);
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/repair/Validator.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/repair/Validator.java b/src/java/org/apache/cassandra/repair/Validator.java
index e7efcaa..2872528 100644
--- a/src/java/org/apache/cassandra/repair/Validator.java
+++ b/src/java/org/apache/cassandra/repair/Validator.java
@@ -119,7 +119,7 @@ public class Validator implements Runnable
}
}
}
- logger.debug("Prepared AEService tree of size " + tree.size() + " for " + desc);
+ logger.debug("Prepared AEService tree of size {} for {}", tree.size(), desc);
ranges = tree.invalids();
}
@@ -211,9 +211,9 @@ public class Validator implements Runnable
if (logger.isDebugEnabled())
{
// log distribution of rows in tree
- logger.debug("Validated " + validated + " rows into AEService tree for " + desc + " with row count distribution:");
+ logger.debug("Validated {} rows into AEService tree for {} with row count distribution:", validated, desc);
tree.histogramOfRowCountPerLeaf().log(logger);
- logger.debug("Validated " + validated + " rows into AEService tree for " + desc + " with row size distribution:");
+ logger.debug("Validated {} rows into AEService tree for {} with row size distribution:", validated, desc);
tree.histogramOfRowSizePerLeaf().log(logger);
}
}
@@ -239,7 +239,7 @@ public class Validator implements Runnable
*/
public void fail()
{
- logger.error("Failed creating a merkle tree for " + desc + ", " + initiator + " (see log for details)");
+ logger.error("Failed creating a merkle tree for {}, {} (see log for details)", desc, initiator);
// send fail message only to nodes >= version 2.0
MessagingService.instance().sendOneWay(new ValidationComplete(desc).createMessage(), initiator);
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/service/CassandraDaemon.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/CassandraDaemon.java b/src/java/org/apache/cassandra/service/CassandraDaemon.java
index 536f319..b99d625 100644
--- a/src/java/org/apache/cassandra/service/CassandraDaemon.java
+++ b/src/java/org/apache/cassandra/service/CassandraDaemon.java
@@ -131,8 +131,8 @@ public class CassandraDaemon
public void uncaughtException(Thread t, Throwable e)
{
StorageMetrics.exceptions.inc();
- logger.error("Exception in thread " + t, e);
- Tracing.trace("Exception in thread " + t, e);
+ logger.error("Exception in thread {}", t, e);
+ Tracing.trace("Exception in thread {}", t, e);
for (Throwable e2 = e; e2 != null; e2 = e2.getCause())
{
// some code, like FileChannel.map, will wrap an OutOfMemoryError in another exception
@@ -142,7 +142,7 @@ public class CassandraDaemon
if (e2 instanceof FSError)
{
if (e2 != e) // make sure FSError gets logged exactly once.
- logger.error("Exception in thread " + t, e2);
+ logger.error("Exception in thread {}", t, e2);
FileUtils.handleFSError((FSError) e2);
}
}
@@ -201,7 +201,7 @@ public class CassandraDaemon
for (String keyspaceName : Schema.instance.getKeyspaces())
{
if (logger.isDebugEnabled())
- logger.debug("opening keyspace " + keyspaceName);
+ logger.debug("opening keyspace {}", keyspaceName);
// disable auto compaction until commit log replay ends
for (ColumnFamilyStore cfs : Keyspace.open(keyspaceName).getColumnFamilyStores())
{
@@ -386,7 +386,7 @@ public class CassandraDaemon
}
catch (Exception e)
{
- logger.error("error registering MBean " + MBEAN_NAME, e);
+ logger.error("error registering MBean {}", MBEAN_NAME, e);
//Allow the server to start even if the bean can't be registered
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/service/MigrationManager.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/MigrationManager.java b/src/java/org/apache/cassandra/service/MigrationManager.java
index fbb7944..5cbb0c8 100644
--- a/src/java/org/apache/cassandra/service/MigrationManager.java
+++ b/src/java/org/apache/cassandra/service/MigrationManager.java
@@ -322,7 +322,7 @@ public class MigrationManager implements IEndpointStateChangeSubscriber
public static void passiveAnnounce(UUID version)
{
Gossiper.instance.addLocalApplicationState(ApplicationState.SCHEMA, StorageService.instance.valueFactory.schema(version));
- logger.debug("Gossiping my schema version " + version);
+ logger.debug("Gossiping my schema version {}", version);
}
/**
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/service/RowDataResolver.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/RowDataResolver.java b/src/java/org/apache/cassandra/service/RowDataResolver.java
index 00f8753..2cbda33 100644
--- a/src/java/org/apache/cassandra/service/RowDataResolver.java
+++ b/src/java/org/apache/cassandra/service/RowDataResolver.java
@@ -58,7 +58,7 @@ public class RowDataResolver extends AbstractRowResolver
public Row resolve() throws DigestMismatchException
{
if (logger.isDebugEnabled())
- logger.debug("resolving " + replies.size() + " responses");
+ logger.debug("resolving {} responses", replies.size());
long start = System.nanoTime();
ColumnFamily resolved;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/service/RowDigestResolver.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/RowDigestResolver.java b/src/java/org/apache/cassandra/service/RowDigestResolver.java
index bc4cf49..b60ad39 100644
--- a/src/java/org/apache/cassandra/service/RowDigestResolver.java
+++ b/src/java/org/apache/cassandra/service/RowDigestResolver.java
@@ -59,7 +59,7 @@ public class RowDigestResolver extends AbstractRowResolver
public Row resolve() throws DigestMismatchException
{
if (logger.isDebugEnabled())
- logger.debug("resolving " + replies.size() + " responses");
+ logger.debug("resolving {} responses", replies.size());
long start = System.nanoTime();
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/service/StorageService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java
index 088fe98..29b5287 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -457,9 +457,9 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
public synchronized void initServer(int delay) throws ConfigurationException
{
- logger.info("Cassandra version: " + FBUtilities.getReleaseVersionString());
- logger.info("Thrift API version: " + cassandraConstants.VERSION);
- logger.info("CQL supported versions: " + StringUtils.join(ClientState.getCQLSupportedVersion(), ",") + " (default: " + ClientState.DEFAULT_CQL_VERSION + ")");
+ logger.info("Cassandra version: {}", FBUtilities.getReleaseVersionString());
+ logger.info("Thrift API version: {}", cassandraConstants.VERSION);
+ logger.info("CQL supported versions: {} (default: {})", StringUtils.join(ClientState.getCQLSupportedVersion(), ","), ClientState.DEFAULT_CQL_VERSION);
if (initialized)
{
@@ -709,7 +709,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
{
tokens = BootStrapper.getRandomTokens(tokenMetadata, DatabaseDescriptor.getNumTokens());
if (DatabaseDescriptor.getNumTokens() == 1)
- logger.warn("Generated random token " + tokens + ". Random tokens will result in an unbalanced ring; see http://wiki.apache.org/cassandra/Operations");
+ logger.warn("Generated random token {}. Random tokens will result in an unbalanced ring; see http://wiki.apache.org/cassandra/Operations", tokens);
else
logger.info("Generated random tokens. tokens are {}", tokens);
}
@@ -718,7 +718,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
tokens = new ArrayList<Token>(initialTokens.size());
for (String token : initialTokens)
tokens.add(getPartitioner().getTokenFactory().fromString(token));
- logger.info("Saved token not found. Using " + tokens + " from configuration");
+ logger.info("Saved token not found. Using {} from configuration", tokens);
}
}
else
@@ -728,7 +728,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
if (tokens.size() == 1 && DatabaseDescriptor.getNumTokens() > 1)
{
// wait for ring info
- logger.info("Sleeping for ring delay (" + delay + "ms)");
+ logger.info("Sleeping for ring delay ({}ms)", delay);
Uninterruptibles.sleepUninterruptibly(delay, TimeUnit.MILLISECONDS);
logger.info("Calculating new tokens");
// calculate num_tokens tokens evenly spaced in the range (left, right]
@@ -764,10 +764,10 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
}
tokens.add(midpoint);
}
- logger.info("Split previous range (" + left + ", " + right + "] into " + tokens);
+ logger.info("Split previous range ({}, {}] into {}", left, right, tokens);
}
else
- logger.info("Using saved token " + tokens);
+ logger.info("Using saved token {}", tokens);
}
}
@@ -1285,7 +1285,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
tokens = getTokensFor(endpoint, pieces[1]);
if (logger.isDebugEnabled())
- logger.debug("Node " + endpoint + " state bootstrapping, token " + tokens);
+ logger.debug("Node {} state bootstrapping, token {}", endpoint, tokens);
// if this node is present in token metadata, either we have missed intermediate states
// or the node had crashed. Print warning if needed, clear obsolete stuff and
@@ -1298,7 +1298,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
// common (not enough time for gossip to spread). Therefore we report only the
// former in the log.
if (!tokenMetadata.isLeaving(endpoint))
- logger.info("Node " + endpoint + " state jump to bootstrap");
+ logger.info("Node {} state jump to bootstrap", endpoint);
tokenMetadata.removeEndpoint(endpoint);
}
@@ -1329,10 +1329,10 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
tokens = getTokensFor(endpoint, pieces[1]);
if (logger.isDebugEnabled())
- logger.debug("Node " + endpoint + " state normal, token " + tokens);
+ logger.debug("Node {} state normal, token {}", endpoint, tokens);
if (tokenMetadata.isMember(endpoint))
- logger.info("Node " + endpoint + " state jump to normal");
+ logger.info("Node {} state jump to normal", endpoint);
// Order Matters, TM.updateHostID() should be called before TM.updateNormalToken(), (see CASSANDRA-4300).
if (Gossiper.instance.usesHostId(endpoint))
@@ -1356,7 +1356,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
InetAddress currentOwner = tokenMetadata.getEndpoint(token);
if (currentOwner == null)
{
- logger.debug("New node " + endpoint + " at token " + token);
+ logger.debug("New node {} at token {}", endpoint, token);
tokensToUpdateInMetadata.add(token);
if (!isClientMode)
tokensToUpdateInSystemKeyspace.add(token);
@@ -1461,19 +1461,19 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
tokens = getTokensFor(endpoint, pieces[1]);
if (logger.isDebugEnabled())
- logger.debug("Node " + endpoint + " state leaving, tokens " + tokens);
+ logger.debug("Node {} state leaving, tokens {}", endpoint, tokens);
// If the node is previously unknown or tokens do not match, update tokenmetadata to
// have this node as 'normal' (it must have been using this token before the
// leave). This way we'll get pending ranges right.
if (!tokenMetadata.isMember(endpoint))
{
- logger.info("Node " + endpoint + " state jump to leaving");
+ logger.info("Node {} state jump to leaving", endpoint);
tokenMetadata.updateNormalTokens(tokens, endpoint);
}
else if (!tokenMetadata.getTokens(endpoint).containsAll(tokens))
{
- logger.warn("Node " + endpoint + " 'leaving' token mismatch. Long network partition?");
+ logger.warn("Node {} 'leaving' token mismatch. Long network partition?", endpoint);
tokenMetadata.updateNormalTokens(tokens, endpoint);
}
@@ -1496,7 +1496,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
tokens = getTokensFor(endpoint, pieces[1]);
if (logger.isDebugEnabled())
- logger.debug("Node " + endpoint + " state left, tokens " + tokens);
+ logger.debug("Node {} state left, tokens {}", endpoint, tokens);
excise(tokens, endpoint, extractExpireTime(pieces));
}
@@ -1513,7 +1513,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
Token token = getPartitioner().getTokenFactory().fromString(pieces[1]);
if (logger.isDebugEnabled())
- logger.debug("Node " + endpoint + " state moving, new token " + token);
+ logger.debug("Node {} state moving, new token {}", endpoint, token);
tokenMetadata.addMovingEndpoint(token, endpoint);
@@ -1575,7 +1575,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
else if (VersionedValue.REMOVING_TOKEN.equals(state))
{
if (logger.isDebugEnabled())
- logger.debug("Tokens " + removeTokens + " removed manually (endpoint was " + endpoint + ")");
+ logger.debug("Tokens {} removed manually (endpoint was {})", removeTokens, endpoint);
// Note that the endpoint is being removed
tokenMetadata.addLeavingEndpoint(endpoint);
@@ -1597,7 +1597,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
private void excise(Collection<Token> tokens, InetAddress endpoint)
{
- logger.info("Removing tokens " + tokens + " for " + endpoint);
+ logger.info("Removing tokens {} for {}", tokens, endpoint);
HintedHandOffManager.instance.deleteHintsForEndpoint(endpoint);
removeEndpoint(endpoint);
tokenMetadata.removeEndpoint(endpoint);
@@ -1753,7 +1753,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
tm.setPendingRanges(keyspaceName, pendingRanges);
if (logger.isDebugEnabled())
- logger.debug("Pending ranges:\n" + (pendingRanges.isEmpty() ? "<empty>" : tm.printPendingRanges()));
+ logger.debug("Pending ranges:\n{}", (pendingRanges.isEmpty() ? "<empty>" : tm.printPendingRanges()));
}
/**
@@ -1802,7 +1802,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
MessageOut msg = new MessageOut(MessagingService.Verb.REPLICATION_FINISHED);
IFailureDetector failureDetector = FailureDetector.instance;
if (logger.isDebugEnabled())
- logger.debug("Notifying " + remote.toString() + " of replication completion\n");
+ logger.debug("Notifying {} of replication completion\n", remote);
while (failureDetector.isAlive(remote))
{
AsyncOneResponse iar = MessagingService.instance().sendRR(msg, remote);
@@ -1858,7 +1858,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
final InetAddress source = entry.getKey();
Collection<Range<Token>> ranges = entry.getValue();
if (logger.isDebugEnabled())
- logger.debug("Requesting from " + source + " ranges " + StringUtils.join(ranges, ", "));
+ logger.debug("Requesting from {} ranges {}", source, StringUtils.join(ranges, ", "));
stream.requestRanges(source, keyspaceName, ranges);
}
}
@@ -1886,7 +1886,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
Collection<Range<Token>> ranges = getRangesForEndpoint(keyspaceName, endpoint);
if (logger.isDebugEnabled())
- logger.debug("Node " + endpoint + " ranges [" + StringUtils.join(ranges, ", ") + "]");
+ logger.debug("Node {} ranges [{}]", endpoint, StringUtils.join(ranges, ", "));
Map<Range<Token>, List<InetAddress>> currentReplicaEndpoints = new HashMap<Range<Token>, List<InetAddress>>();
@@ -1914,9 +1914,9 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
newReplicaEndpoints.removeAll(currentReplicaEndpoints.get(range));
if (logger.isDebugEnabled())
if (newReplicaEndpoints.isEmpty())
- logger.debug("Range " + range + " already in all replicas");
+ logger.debug("Range {} already in all replicas", range);
else
- logger.debug("Range " + range + " will be responsibility of " + StringUtils.join(newReplicaEndpoints, ", "));
+ logger.debug("Range {} will be responsibility of {}", range, StringUtils.join(newReplicaEndpoints, ", "));
changedRanges.putAll(range, newReplicaEndpoints);
}
@@ -2315,7 +2315,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
{
for (ColumnFamilyStore cfStore : getValidColumnFamilies(true, false, keyspaceName, columnFamilies))
{
- logger.debug("Forcing flush on keyspace " + keyspaceName + ", CF " + cfStore.name);
+ logger.debug("Forcing flush on keyspace {}, CF {}", keyspaceName, cfStore.name);
cfStore.forceBlockingFlush();
}
}
@@ -2472,7 +2472,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
if (names.isEmpty())
{
- logger.info("No column family to repair for keyspace " + keyspaceName);
+ logger.info("No column family to repair for keyspace {}", keyspaceName);
return null;
}
@@ -2545,7 +2545,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
public List<Range<Token>> getAllRanges(List<Token> sortedTokens)
{
if (logger.isDebugEnabled())
- logger.debug("computing ranges for " + StringUtils.join(sortedTokens, ", "));
+ logger.debug("computing ranges for {}", StringUtils.join(sortedTokens, ", "));
if (sortedTokens.isEmpty())
return Collections.emptyList();
@@ -2739,7 +2739,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
Gossiper.instance.addLocalApplicationState(ApplicationState.STATUS, valueFactory.left(getLocalTokens(),Gossiper.computeExpireTime()));
int delay = Math.max(RING_DELAY, Gossiper.intervalInMillis * 2);
- logger.info("Announcing that I have left the ring for " + delay + "ms");
+ logger.info("Announcing that I have left the ring for {}ms", delay);
Uninterruptibles.sleepUninterruptibly(delay, TimeUnit.MILLISECONDS);
}
@@ -2752,7 +2752,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
Multimap<Range<Token>, InetAddress> rangesMM = getChangedRangesForLeaving(keyspaceName, FBUtilities.getBroadcastAddress());
if (logger.isDebugEnabled())
- logger.debug("Ranges needing transfer are [" + StringUtils.join(rangesMM.keySet(), ",") + "]");
+ logger.debug("Ranges needing transfer are [{}]", StringUtils.join(rangesMM.keySet(), ","));
rangesToStream.put(keyspaceName, rangesMM);
}
@@ -2955,7 +2955,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
{
Set<InetAddress> currentEndpoints = ImmutableSet.copyOf(strategy.calculateNaturalEndpoints(toStream.right, tokenMetaClone));
Set<InetAddress> newEndpoints = ImmutableSet.copyOf(strategy.calculateNaturalEndpoints(toStream.right, tokenMetaCloneAllSettled));
- logger.debug("Range:" + toStream + "Current endpoints: " + currentEndpoints + " New endpoints: " + newEndpoints);
+ logger.debug("Range: {} Current endpoints: {} New endpoints: {}", toStream, currentEndpoints, newEndpoints);
for (InetAddress address : Sets.difference(newEndpoints, currentEndpoints))
endpointRanges.put(address, toStream);
}
@@ -3081,7 +3081,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
{
if (!replicatingNodes.isEmpty() || !tokenMetadata.getLeavingEndpoints().isEmpty())
{
- logger.warn("Removal not confirmed for for " + StringUtils.join(this.replicatingNodes, ","));
+ logger.warn("Removal not confirmed for for {}", StringUtils.join(this.replicatingNodes, ","));
for (InetAddress endpoint : tokenMetadata.getLeavingEndpoints())
{
UUID hostId = tokenMetadata.getHostId(endpoint);
@@ -3126,7 +3126,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
// A leaving endpoint that is dead is already being removed.
if (tokenMetadata.isLeaving(endpoint))
- logger.warn("Node " + endpoint + " is already being removed, continuing removal anyway");
+ logger.warn("Node {} is already being removed, continuing removal anyway", endpoint);
if (!replicatingNodes.isEmpty())
throw new UnsupportedOperationException("This node is already processing a removal. Wait for it to complete, or use 'removetoken force' if this has failed.");
@@ -3147,7 +3147,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
if (failureDetector.isAlive(ep))
replicatingNodes.add(ep);
else
- logger.warn("Endpoint " + ep + " is down and will not receive data for re-replication of " + endpoint);
+ logger.warn("Endpoint {} is down and will not receive data for re-replication of {}", ep, endpoint);
}
}
removingNode = endpoint;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/streaming/ConnectionHandler.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/ConnectionHandler.java b/src/java/org/apache/cassandra/streaming/ConnectionHandler.java
index 57f76a7..f701a99 100644
--- a/src/java/org/apache/cassandra/streaming/ConnectionHandler.java
+++ b/src/java/org/apache/cassandra/streaming/ConnectionHandler.java
@@ -135,7 +135,7 @@ public class ConnectionHandler
throw e;
long waitms = DatabaseDescriptor.getRpcTimeout() * (long)Math.pow(2, attempts);
- logger.warn("Failed attempt " + attempts + " to connect to " + peer + ". Retrying in " + waitms + " ms. (" + e + ")");
+ logger.warn("Failed attempt {} to connect to {}. Retrying in {} ms. ({})", attempts, peer, waitms, e);
try
{
Thread.sleep(waitms);
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/streaming/ReplicationFinishedVerbHandler.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/ReplicationFinishedVerbHandler.java b/src/java/org/apache/cassandra/streaming/ReplicationFinishedVerbHandler.java
index 4297b34..ce8a921 100644
--- a/src/java/org/apache/cassandra/streaming/ReplicationFinishedVerbHandler.java
+++ b/src/java/org/apache/cassandra/streaming/ReplicationFinishedVerbHandler.java
@@ -35,7 +35,7 @@ public class ReplicationFinishedVerbHandler implements IVerbHandler
StorageService.instance.confirmReplication(msg.from);
MessageOut response = new MessageOut(MessagingService.Verb.INTERNAL_RESPONSE);
if (logger.isDebugEnabled())
- logger.debug("Replying to " + id + "@" + msg.from);
+ logger.debug("Replying to {}@{}", id, msg.from);
MessagingService.instance().sendReply(response, id, msg.from);
}
}
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/streaming/StreamSession.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/StreamSession.java b/src/java/org/apache/cassandra/streaming/StreamSession.java
index 5a16d81..92e5926 100644
--- a/src/java/org/apache/cassandra/streaming/StreamSession.java
+++ b/src/java/org/apache/cassandra/streaming/StreamSession.java
@@ -407,7 +407,7 @@ public class StreamSession implements IEndpointStateChangeSubscriber, IFailureDe
*/
public void onError(Throwable e)
{
- logger.error("[Stream #" + planId() + "] Streaming error occurred", e);
+ logger.error("[Stream #{}] Streaming error occurred", planId(), e);
// send session failure message
if (handler.isOutgoingConnected())
handler.sendMessage(new SessionFailedMessage());
@@ -516,7 +516,7 @@ public class StreamSession implements IEndpointStateChangeSubscriber, IFailureDe
public void doRetry(FileMessageHeader header, Throwable e)
{
- logger.warn("[Stream #" + planId() + "] Retrying for following error", e);
+ logger.warn("[Stream #{}] Retrying for following error", planId(), e);
// retry
retries++;
if (retries > DatabaseDescriptor.getMaxStreamingRetries())
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/thrift/CassandraServer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/thrift/CassandraServer.java b/src/java/org/apache/cassandra/thrift/CassandraServer.java
index 8edb1d3..2fbd504 100644
--- a/src/java/org/apache/cassandra/thrift/CassandraServer.java
+++ b/src/java/org/apache/cassandra/thrift/CassandraServer.java
@@ -1364,7 +1364,7 @@ public class CassandraServer implements Cassandra.Iface
}
catch (NotFoundException nfe)
{
- logger.info("Failed to find metadata for keyspace '" + ks + "'. Continuing... ");
+ logger.info("Failed to find metadata for keyspace '{}'. Continuing... ", ks);
}
}
return ksset;
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java b/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java
index cf48502..7dc1bd9 100644
--- a/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java
+++ b/src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java
@@ -119,7 +119,7 @@ public class CustomTThreadPoolServer extends TServer
}
if (activeClients.get() >= args.maxWorkerThreads)
- logger.warn("Maximum number of clients " + args.maxWorkerThreads + " reached");
+ logger.warn("Maximum number of clients {} reached", args.maxWorkerThreads);
}
executorService.shutdown();
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/thrift/ThriftValidation.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/thrift/ThriftValidation.java b/src/java/org/apache/cassandra/thrift/ThriftValidation.java
index 012a943..8fb2e50 100644
--- a/src/java/org/apache/cassandra/thrift/ThriftValidation.java
+++ b/src/java/org/apache/cassandra/thrift/ThriftValidation.java
@@ -446,7 +446,7 @@ public class ThriftValidation
catch (MarshalException me)
{
if (logger.isDebugEnabled())
- logger.debug("rejecting invalid value " + ByteBufferUtil.bytesToHex(summarize(column.value)));
+ logger.debug("rejecting invalid value {}", ByteBufferUtil.bytesToHex(summarize(column.value)));
throw new org.apache.cassandra.exceptions.InvalidRequestException(String.format("(%s) [%s][%s][%s] failed validation",
me.getMessage(),
http://git-wip-us.apache.org/repos/asf/cassandra/blob/db9bc692/src/java/org/apache/cassandra/utils/CLibrary.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/utils/CLibrary.java b/src/java/org/apache/cassandra/utils/CLibrary.java
index 6711098..a7ff815 100644
--- a/src/java/org/apache/cassandra/utils/CLibrary.java
+++ b/src/java/org/apache/cassandra/utils/CLibrary.java
@@ -65,7 +65,7 @@ public final class CLibrary
catch (UnsatisfiedLinkError e)
{
logger.info("JNA link failure, one or more native method will be unavailable.");
- logger.debug("JNA link failure details: " + e.getMessage());
+ logger.debug("JNA link failure details: {}", e.getMessage());
}
catch (NoSuchMethodError e)
{
@@ -137,7 +137,7 @@ public final class CLibrary
else if (!System.getProperty("os.name").toLowerCase().contains("mac"))
{
// OS X allows mlockall to be called, but always returns an error
- logger.warn("Unknown mlockall error " + errno(e));
+ logger.warn("Unknown mlockall error {}", errno(e));
}
}
}