Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2321#discussion_r191148429
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/store/CarbonFactDataHandlerModel.java
---
@@ -258,15 +258,13 @@ public static CarbonFactDataHandlerModel
createCarbonFactDataHandlerModel(
carbonFactDataHandlerModel.tableSpec = configuration.getTableSpec();
carbonFactDataHandlerModel.sortScope =
CarbonDataProcessorUtil.getSortScope(configuration);
- DataMapWriterListener listener = new DataMapWriterListener();
- listener.registerAllWriter(
- configuration.getTableSpec().getCarbonTable(),
- configuration.getSegmentId(),
- CarbonTablePath.getShardName(
- carbonDataFileAttributes.getTaskId(),
- bucketId,
- 0,
- String.valueOf(carbonDataFileAttributes.getFactTimeStamp())));
+ if (listener == null) {
+ listener = new DataMapWriterListener();
+
listener.registerAllWriter(configuration.getTableSpec().getCarbonTable(),
+ configuration.getSegmentId(), CarbonTablePath
--- End diff --
change the format like original code
---
