You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2019/07/19 20:12:38 UTC

[incubator-iceberg] branch master updated: Minor: Fix storage descriptor classes (#300)

This is an automated email from the ASF dual-hosted git repository.

blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new 86c3d03  Minor: Fix storage descriptor classes (#300)
86c3d03 is described below

commit 86c3d030cd45ced15f382f9f37a349fe3f874a41
Author: Anton Okolnychyi <ao...@apple.com>
AuthorDate: Fri Jul 19 23:12:33 2019 +0300

    Minor: Fix storage descriptor classes (#300)
---
 hive/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java | 4 ++--
 1 file changed, 2 insertions(+), 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
index 1d13024..37cbf79 100644
--- 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 @@ public class HiveTableOperations extends BaseMetastoreTableOperations {
     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);