Github user ajantha-bhat commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2141#discussion_r181648562
--- Diff:
core/src/main/java/org/apache/carbondata/core/scan/executor/util/RestructureUtil.java
---
@@ -354,7 +369,13 @@ public static Object
getMeasureDefaultValueByType(ColumnSchema columnSchema,
// then setting measure exists is true
// otherwise adding a default value of a measure
for (CarbonMeasure carbonMeasure : currentBlockMeasures) {
- if
(carbonMeasure.getColumnId().equals(queryMeasure.getMeasure().getColumnId())) {
+ // If it is unmanaged table just check the column names, no need
to validate column id as
+ // multiple sdk's output placed in a single folder doesn't have
same column ID but can
+ // have same column name
+ if
(carbonMeasure.getColumnId().equals(queryMeasure.getMeasure().getColumnId()) ||
+ ((queryModel != null) &&
(queryModel.getTable().getTableInfo().isUnManagedTable()) &&
--- End diff --
ok
---
