Github user manishgupta88 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2109#discussion_r178719497
--- Diff:
hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonOutputCommitter.java
---
@@ -130,15 +130,20 @@ public CarbonOutputCommitter(Path outputPath,
TaskAttemptContext context) throws
loadModel.getTablePath());
newMetaEntry.setSegmentFile(segmentFileName +
CarbonTablePath.SEGMENT_EXT);
}
+ OperationContext operationContext = (OperationContext)
getOperationContext();
+ String uuid = "";
+ if
(loadModel.getCarbonDataLoadSchema().getCarbonTable().isChildDataMap() &&
+ operationContext != null) {
+ uuid = operationContext.getProperty("uuid").toString();
+ }
CarbonLoaderUtil
.populateNewLoadMetaEntry(newMetaEntry, SegmentStatus.SUCCESS,
loadModel.getFactTimeStamp(),
true);
CarbonTable carbonTable =
loadModel.getCarbonDataLoadSchema().getCarbonTable();
long segmentSize = CarbonLoaderUtil
.addDataIndexSizeIntoMetaEntry(newMetaEntry,
loadModel.getSegmentId(), carbonTable);
if (segmentSize > 0 || overwriteSet) {
- Object operationContext = getOperationContext();
- if (operationContext != null) {
+ if (operationContext != null && carbonTable.hasAggregationDataMap())
{
((OperationContext) operationContext)
--- End diff --
Remove typecasting again
---
