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 <[email protected]> Authored: Thu Aug 10 11:10:54 2017 -0700 Committer: Abhishek Tiwari <[email protected]> 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());
