Repository: carbondata Updated Branches: refs/heads/master 582916fb5 -> d94d21d63
[CARBONDATA-2119]deserialization issue for carbonloadmodel Problem: Load model was not getting de-serialized in the executor due to which 2 different carbon table objects were being created. Solution: Reconstruct carbonTable from tableInfo if not already created. This closes #1947 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/d94d21d6 Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/d94d21d6 Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/d94d21d6 Branch: refs/heads/master Commit: d94d21d6324d2a614eb73e2432d1dc11c1a09078 Parents: 582916f Author: akashrn5 <akashnilu...@gmail.com> Authored: Wed Feb 7 18:44:33 2018 +0530 Committer: ravipesala <ravi.pes...@gmail.com> Committed: Thu Feb 8 22:49:17 2018 +0530 ---------------------------------------------------------------------- .../carbondata/processing/loading/model/CarbonDataLoadSchema.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/d94d21d6/processing/src/main/java/org/apache/carbondata/processing/loading/model/CarbonDataLoadSchema.java ---------------------------------------------------------------------- diff --git a/processing/src/main/java/org/apache/carbondata/processing/loading/model/CarbonDataLoadSchema.java b/processing/src/main/java/org/apache/carbondata/processing/loading/model/CarbonDataLoadSchema.java index a9d7bd8..72de613 100644 --- a/processing/src/main/java/org/apache/carbondata/processing/loading/model/CarbonDataLoadSchema.java +++ b/processing/src/main/java/org/apache/carbondata/processing/loading/model/CarbonDataLoadSchema.java @@ -57,7 +57,7 @@ public class CarbonDataLoadSchema implements Serializable { */ public CarbonTable getCarbonTable() { if (!updatedDataTypes) { - CarbonTable.updateTableInfo(carbonTable.getTableInfo()); + carbonTable = CarbonTable.buildFromTableInfo(carbonTable.getTableInfo()); updatedDataTypes = true; } return carbonTable;
