Repository: carbondata Updated Branches: refs/heads/master 9d7a9a2a9 -> 0fb1e02a9
[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. Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/0fb1e02a Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/0fb1e02a Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/0fb1e02a Branch: refs/heads/master Commit: 0fb1e02a94ed1032598c99807516e34e0ed63e00 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:22:20 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/0fb1e02a/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()),
