Author: jbellis Date: Tue Jul 27 01:50:32 2010 New Revision: 979494 URL: http://svn.apache.org/viewvc?rev=979494&view=rev Log: restore exception message containing row key to debug message for DME. patch by jbellis
Modified: cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/service/StorageProxy.java Modified: cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/service/StorageProxy.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/service/StorageProxy.java?rev=979494&r1=979493&r2=979494&view=diff ============================================================================== --- cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/service/StorageProxy.java (original) +++ cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/service/StorageProxy.java Tue Jul 27 01:50:32 2010 @@ -499,10 +499,11 @@ public class StorageProxy implements Sto { if (DatabaseDescriptor.getConsistencyCheck()) { + if (logger.isDebugEnabled()) + logger.debug("Digest mismatch:", ex); int responseCount = determineBlockFor(DatabaseDescriptor.getReplicationFactor(command.table), consistency_level); IResponseResolver<Row> readResponseResolverRepair = new ReadResponseResolver(command.table, responseCount); QuorumResponseHandler<Row> quorumResponseHandlerRepair = new QuorumResponseHandler<Row>(responseCount, readResponseResolverRepair); - logger.debug("Digest mismatch; requesting full data from each replica"); Message messageRepair = command.makeReadMessage(); MessagingService.instance.sendRR(messageRepair, commandEndPoints.get(commandIndex), quorumResponseHandlerRepair); try