svn commit: r1036932 - /cassandra/trunk/src/java/org/apache/cassandra/cql/QueryProcessor.java

[gd...@apache.org]

Author: gdusbabek
Date: Fri Nov 19 16:39:50 2010
New Revision: 1036932

URL: http://svn.apache.org/viewvc?rev=1036932&view=rev
Log:
fix build

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/cql/QueryProcessor.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/cql/QueryProcessor.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/cql/QueryProcessor.java?rev=1036932&r1=1036931&r2=1036932&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/cql/QueryProcessor.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/cql/QueryProcessor.java Fri Nov 19 16:39:50 2010
@@ -173,7 +173,7 @@ public class QueryProcessor
     }
     
     private static List<org.apache.cassandra.db.Row> getIndexedSlices(String keyspace, SelectStatement select)
-    throws TimedOutException
+    throws TimedOutException, UnavailableException
     {
         // XXX: Our use of Thrift structs internally (still) makes me Sad. :~(
         SlicePredicate thriftSlicePredicate = slicePredicateFromSelect(select);
@@ -198,6 +198,14 @@ public class QueryProcessor
                                      thriftSlicePredicate,
                                      select.getConsistencyLevel());
         }
+        catch (org.apache.cassandra.thrift.UnavailableException ex) 
+        {
+            UnavailableException avroEx = new UnavailableException();
+            avroEx.why = ex.getMessage();
+            if (avroEx.why == null || avroEx.why.length() == 0)
+                avroEx.why = "StorageProxy.scan() failed because of insufficent responses.";
+            throw avroEx;
+        }
         catch (IOException e)
         {
             throw new RuntimeException(e);