diff --git a/src/main/scala/org/kududb/spark/DefaultSource.scala b/src/main/scala/org/kududb/spark/DefaultSource.scala
index caa4655..2ae4567 100644
--- a/src/main/scala/org/kududb/spark/DefaultSource.scala
+++ b/src/main/scala/org/kududb/spark/DefaultSource.scala
@@ -172,7 +172,7 @@ class KuduRelation (val tableName:String,
 
 
     val columnSchema = getKuduSchemaColumnMap.getOrElse(columnName, null)
-    val columnIndex = row.getColumnProjection.getColumnIndex(columnSchema)
+    val columnIndex = row.getColumnProjection.getColumnIndex(columnName)
     val columnType = columnSchema.getType
 
     if (columnType == Type.BINARY) row.getBinary(columnIndex)