cleanup
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/abde62d0 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/abde62d0 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/abde62d0 Branch: refs/heads/trunk Commit: abde62d04a6ea333b5107e03b0e1a983f9b3b733 Parents: ba68130 Author: Jonathan Ellis <jbel...@apache.org> Authored: Sat Oct 11 17:09:13 2014 -0500 Committer: Jonathan Ellis <jbel...@apache.org> Committed: Mon Oct 20 11:38:43 2014 -0700 ---------------------------------------------------------------------- src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/abde62d0/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java index eedaa17..d052d73 100644 --- a/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java +++ b/src/java/org/apache/cassandra/hadoop/cql3/CqlRecordReader.java @@ -32,7 +32,6 @@ import com.google.common.collect.AbstractIterator; import com.google.common.collect.Iterables; import com.google.common.collect.Maps; -import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang.StringUtils; import org.apache.cassandra.hadoop.HadoopCompat; @@ -580,7 +579,7 @@ public class CqlRecordReader extends RecordReader<Long, Row> String query = "SELECT column_name, component_index, type FROM system.schema_columns WHERE keyspace_name='" + keyspace + "' and columnfamily_name='" + cfName + "'"; List<Row> rows = session.execute(query).all(); - if (CollectionUtils.isEmpty(rows)) + if (rows.isEmpty()) { throw new RuntimeException("No table metadata found for " + keyspace + "." + cfName); }
