Github user chenliang613 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1581#discussion_r155176489
--- Diff:
core/src/main/java/org/apache/carbondata/core/scan/collector/impl/RestructureBasedVectorResultCollector.java
---
@@ -238,7 +238,7 @@ private void fillDataForNonExistingMeasures() {
(long) defaultValue);
} else if (DataTypes.isDecimal(dataType)) {
vector.putDecimals(columnVectorInfo.vectorOffset,
columnVectorInfo.size,
- (Decimal) defaultValue, measure.getPrecision());
+ ((Decimal) defaultValue).toJavaBigDecimal(),
measure.getPrecision());
--- End diff --
please remove these import :
import org.apache.spark.sql.types.Decimal;
import org.apache.spark.unsafe.types.UTF8String;
---
