diff --git a/src/java/org/apache/cassandra/avro/AvroValidation.java b/src/java/org/apache/cassandra/avro/AvroValidation.java
index <HASH>..<HASH> 100644
--- a/src/java/org/apache/cassandra/avro/AvroValidation.java
+++ b/src/java/org/apache/cassandra/avro/AvroValidation.java
@@ -348,7 +348,7 @@ public class AvroValidation
         Set<byte[]> indexedColumns = Table.open(keyspace).getColumnFamilyStore(columnFamily).getIndexedColumns();
         for (IndexExpression expression : index_clause.expressions)
         {
-            if (expression.op.equals(IndexOperator.EQ) && indexedColumns.contains(expression.column_name))
+            if (expression.op.equals(IndexOperator.EQ) && indexedColumns.contains(expression.column_name.array()))
                 return;
         }
         throw newInvalidRequestException("No indexed columns present in index clause with operator EQ");
extract array from ByteBuffer in AvroValidation.validateIndexClauses.  Patch by gdusbabek, reviewed by brandonwilliams

git-svn-id: <URL>