Minor: Fix storage descriptor classes (apache#300)

Guosmilesmile · Jul 19, 2019 · 86c3d03 · 86c3d03
1 parent cfd2737
commit 86c3d03
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/hive/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java b/hive/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java
@@ -208,8 +208,8 @@ private StorageDescriptor storageDescriptor(TableMetadata metadata) {
     final StorageDescriptor storageDescriptor = new StorageDescriptor();
     storageDescriptor.setCols(columns(metadata.schema()));
     storageDescriptor.setLocation(metadata.location());
-    storageDescriptor.setOutputFormat("org.apache.hadoop.mapred.FileInputFormat");
-    storageDescriptor.setInputFormat("org.apache.hadoop.mapred.FileOutputFormat");
+    storageDescriptor.setOutputFormat("org.apache.hadoop.mapred.FileOutputFormat");
+    storageDescriptor.setInputFormat("org.apache.hadoop.mapred.FileInputFormat");
     SerDeInfo serDeInfo = new SerDeInfo();
     serDeInfo.setSerializationLib("org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe");
     storageDescriptor.setSerdeInfo(serDeInfo);