Fixed issue where serde info parameters were not getting stored when …

…creating a s3 table.
Netflix · Mar 24, 2016 · e3ecbfc · e3ecbfc
1 parent ca81511
commit e3ecbfc
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/metacat-s3-connector/src/main/java/com/netflix/metacat/s3/connector/util/ConverterUtil.java b/metacat-s3-connector/src/main/java/com/netflix/metacat/s3/connector/util/ConverterUtil.java
@@ -39,6 +39,7 @@
 import javax.inject.Inject;
 import java.util.Comparator;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
@@ -62,7 +63,7 @@ public StorageInfo toStorageInfo(Table table){
                 result.setInputFormat(info.getInputFormat());
                 result.setOutputFormat(info.getOutputFormat());
                 result.setSerializationLib(info.getSerializationLib());
-                result.setParameters(Maps.newHashMap(info.getParameters()));
+                result.setSerdeInfoParameters(Maps.newHashMap(info.getParameters()));
             }
         }
         return result;
@@ -90,7 +91,14 @@ public Location fromStorageInfo(StorageInfo storageInfo, String owner){
             info.setInputFormat( storageInfo.getInputFormat());
             info.setOutputFormat( storageInfo.getOutputFormat());
             info.setSerializationLib( storageInfo.getSerializationLib());
-            info.setParameters( storageInfo.getParameters());
+            Map<String, String> parameters = Maps.newHashMap();
+            if( storageInfo.getParameters() != null){
+                parameters.putAll(storageInfo.getParameters());
+            }
+            if( storageInfo.getSerdeInfoParameters() != null){
+                parameters.putAll(storageInfo.getSerdeInfoParameters());
+            }
+            info.setParameters( parameters);
             result.setInfo(info);
         } else if ( owner != null){
             Info info = new Info();