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 2009/06/18 13:46:39 UTC
svn commit: r786025 -
/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
Author: jbellis
Date: Thu Jun 18 11:46:39 2009
New Revision: 786025
URL: http://svn.apache.org/viewvc?rev=786025&view=rev
Log:
rethrow IOException with more details. patch by jbellis; reviewed by Jun Rao for CASSANDRA-202
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java?rev=786025&r1=786024&r2=786025&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java Thu Jun 18 11:46:39 2009
@@ -550,7 +550,15 @@
{
continue;
}
- ColumnFamily columnFamily = fetchColumnFamily(key, cf, filter, file);
+ ColumnFamily columnFamily = null;
+ try
+ {
+ columnFamily = fetchColumnFamily(key, cf, filter, file);
+ }
+ catch (IOException e)
+ {
+ throw new IOException("Error fetching " + key + ":" + cf + " from " + file, e);
+ }
if (columnFamily != null)
{
columnFamilies.add(columnFamily);