Github user ravipesala commented on a diff in the pull request: https://github.com/apache/carbondata/pull/1581#discussion_r154838503 --- Diff: integration/spark2/src/main/java/org/apache/carbondata/spark/vectorreader/ColumnarVectorWrapper.java --- @@ -200,7 +205,7 @@ public ColumnarVectorWrapper(ColumnVector columnVector, boolean[] filteredRows) } @Override public DataType getType() { - return columnVector.dataType(); + return CarbonScalaUtil.convertSparkToCarbonDataType(columnVector.dataType()); --- End diff -- store the dataType as class variable, don't convert each time.
---