Skip to content

Commit 60295ab

Browse files
author
Tom May
committed
Tweak cassandra logging.
1 parent c33c022 commit 60295ab

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

plugins/cassandra/src/main/java/org/elasticsearch/cassandra/blobstore/AbstractCassandraBlobContainer.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ public AbstractCassandraBlobContainer(BlobPath path, CassandraBlobStore blobStor
9191
}
9292

9393
@Override public boolean deleteBlob(String blobName) throws IOException {
94-
logger.debug("TODO deleteBlob blobName={}", blobName);
94+
logger.debug("deleteBlob blobName={}", blobName);
9595
Cassandra.Client client =
9696
CassandraClientFactory.getCassandraClient();
9797
try {
@@ -145,8 +145,7 @@ private void readBlob(Cassandra.Client client, String blobName, ReadBlobListener
145145
ConsistencyLevel.QUORUM);
146146
Column column = columnOrSuperColumn.getColumn();
147147
byte[] blobData = column.getValue();
148-
logger.debug("Read {} ({} bytes): {}",
149-
blobName, blobData.length, new String(blobData));
148+
logger.debug("Read {}, {} bytes", blobName, blobData.length);
150149
listener.onPartial(blobData, 0, blobData.length);
151150
listener.onCompleted();
152151
}

plugins/cassandra/src/main/java/org/elasticsearch/cassandra/blobstore/CassandraImmutableBlobContainer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public CassandraImmutableBlobContainer(BlobPath path, CassandraBlobStore blobSto
6464
blobStore.executor().execute(new Runnable() {
6565
@Override public void run() {
6666
try {
67-
logger.debug("writeBlob blobName={}, sizeInBytes={}, is={}", blobName, sizeInBytes, is);
67+
logger.debug("writeBlob blobName={}, sizeInBytes={}", blobName, sizeInBytes);
6868
Cassandra.Client client =
6969
CassandraClientFactory.getCassandraClient();
7070
try {

0 commit comments

Comments
 (0)