Repository: carbondata
Updated Branches:
  refs/heads/branch-1.3 a3b97f384 -> 2c5ecfbfe


[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/2c5ecfbf
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/2c5ecfbf
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/2c5ecfbf

Branch: refs/heads/branch-1.3
Commit: 2c5ecfbfe5ce3357d041207cad8edcf587e4115f
Parents: a3b97f3
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:50:10 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/2c5ecfbf/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;

Reply via email to