[CARBONDATA-2753] Fix Compatibility issue with Preaggregate table Problem: User creates maintable and load data and create preaggregate datamap on maintable using old version and loads data into maintable using new version and dataload fails.
This closes #2523 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/99021f60 Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/99021f60 Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/99021f60 Branch: refs/heads/branch-1.4 Commit: 99021f604df5f7f30464095493097ee519a08ad0 Parents: ffcd635 Author: Indhumathi27 <[email protected]> Authored: Wed Jul 18 20:47:06 2018 +0530 Committer: ravipesala <[email protected]> Committed: Tue Jul 31 00:10:41 2018 +0530 ---------------------------------------------------------------------- .../core/metadata/schema/table/DataMapSchemaFactory.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/99021f60/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java b/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java index e8022cc..99fc403 100644 --- a/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java +++ b/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java @@ -28,9 +28,11 @@ public class DataMapSchemaFactory { * @return data map schema */ public DataMapSchema getDataMapSchema(String dataMapName, String providerName) { - if (providerName.equalsIgnoreCase(DataMapClassProvider.PREAGGREGATE.toString())) { + if (providerName.equalsIgnoreCase(DataMapClassProvider.PREAGGREGATE.toString()) || providerName + .equalsIgnoreCase(DataMapClassProvider.PREAGGREGATE.getClassName())) { return new AggregationDataMapSchema(dataMapName, providerName); - } else if (providerName.equalsIgnoreCase(DataMapClassProvider.TIMESERIES.toString())) { + } else if (providerName.equalsIgnoreCase(DataMapClassProvider.TIMESERIES.toString()) + || providerName.equalsIgnoreCase(DataMapClassProvider.TIMESERIES.getClassName())) { return new AggregationDataMapSchema(dataMapName, providerName); } else { return new DataMapSchema(dataMapName, providerName);
