Repository: incubator-gobblin
Updated Branches:
  refs/heads/master 42ea018e5 -> a48396001


[GOBBLIN-193] Handled NoSuchObjectException while checking for partition in the 
table in AbstractAvroToOrcConverter

Closes #2045 from aditya1105/master


Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/a4839600
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/a4839600
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/a4839600

Branch: refs/heads/master
Commit: a48396001a549788ed5e1d39a195ae8ec68ff968
Parents: 42ea018
Author: aditya1105 <adsha...@linkedin.com>
Authored: Thu Aug 10 11:10:54 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.bt...@gmail.com>
Committed: Thu Aug 10 11:10:54 2017 -0700

----------------------------------------------------------------------
 .../conversion/hive/converter/AbstractAvroToOrcConverter.java      | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/a4839600/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
----------------------------------------------------------------------
diff --git 
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
 
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
index 3738d2a..9c4a5ec 100644
--- 
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
+++ 
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java
@@ -795,6 +795,8 @@ public abstract class AbstractAvroToOrcConverter extends 
Converter<Schema, Schem
       try (AutoReturnableObject<IMetaStoreClient> client = pool.getClient()) {
         partitionOptional =
             Optional.of(client.get().getPartition(table.get().getDbName(), 
table.get().getTableName(), partitionName));
+      } catch (NoSuchObjectException e) {
+        return Optional.<Path>absent();
       }
       if (partitionOptional.isPresent()) {
         org.apache.hadoop.hive.ql.metadata.Table qlTable = new 
org.apache.hadoop.hive.ql.metadata.Table(table.get());

Reply via email to