[HOTFIX][CARBONDATA-2716][DataMap] fix bug for loading datamap In some scenarios, input parameter of getCarbonFactDataHandlerModel called carbonTable may be different from the one in loadmodel.
This close #2497 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/84102a22 Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/84102a22 Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/84102a22 Branch: refs/heads/carbonstore Commit: 84102a22accd3d24d52faccc747a62887c13d502 Parents: 9d7a9a2 Author: Manhua <kevin...@qq.com> Authored: Thu Jul 12 16:47:15 2018 +0800 Committer: xuchuanyin <xuchuan...@hust.edu.cn> Committed: Fri Jul 13 09:25:25 2018 +0800 ---------------------------------------------------------------------- .../carbondata/processing/store/CarbonFactDataHandlerModel.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/84102a22/processing/src/main/java/org/apache/carbondata/processing/store/CarbonFactDataHandlerModel.java ---------------------------------------------------------------------- diff --git a/processing/src/main/java/org/apache/carbondata/processing/store/CarbonFactDataHandlerModel.java b/processing/src/main/java/org/apache/carbondata/processing/store/CarbonFactDataHandlerModel.java index 63e47f0..ca75b8c 100644 --- a/processing/src/main/java/org/apache/carbondata/processing/store/CarbonFactDataHandlerModel.java +++ b/processing/src/main/java/org/apache/carbondata/processing/store/CarbonFactDataHandlerModel.java @@ -332,7 +332,7 @@ public class CarbonFactDataHandlerModel { new TableSpec(loadModel.getCarbonDataLoadSchema().getCarbonTable()); DataMapWriterListener listener = new DataMapWriterListener(); listener.registerAllWriter( - loadModel.getCarbonDataLoadSchema().getCarbonTable(), + carbonTable, loadModel.getSegmentId(), CarbonTablePath.getShardName( CarbonTablePath.DataFileUtil.getTaskIdFromTaskNo(loadModel.getTaskNo()),
