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
