You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/07/27 03:50:32 UTC
svn commit: r979494 -
/cassandra/branches/cassandra-0.6/src/java/org/apache/cassandra/service/StorageProxy.java
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