Repository: incubator-gobblin Updated Branches: refs/heads/master 0dfa2bd91 -> 1213b06e3
Propogating IllegalArgumentException instead of silent failure in HiveDatasetFinder Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/bc571474 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/bc571474 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/bc571474 Branch: refs/heads/master Commit: bc57147446334a519ad61b7c85c9ae88c6f46a31 Parents: 01d85df Author: Aditya Sharma <[email protected]> Authored: Fri Jun 9 05:53:45 2017 -0700 Committer: Aditya Sharma <[email protected]> Committed: Fri Jun 9 05:54:18 2017 -0700 ---------------------------------------------------------------------- .../java/gobblin/data/management/copy/hive/HiveDatasetFinder.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bc571474/gobblin-data-management/src/main/java/gobblin/data/management/copy/hive/HiveDatasetFinder.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/gobblin/data/management/copy/hive/HiveDatasetFinder.java b/gobblin-data-management/src/main/java/gobblin/data/management/copy/hive/HiveDatasetFinder.java index 1159695..9bf2bf6 100644 --- a/gobblin-data-management/src/main/java/gobblin/data/management/copy/hive/HiveDatasetFinder.java +++ b/gobblin-data-management/src/main/java/gobblin/data/management/copy/hive/HiveDatasetFinder.java @@ -17,6 +17,7 @@ package gobblin.data.management.copy.hive; +import com.google.common.base.Throwables; import java.io.IOException; import java.lang.reflect.InvocationTargetException; import java.net.URISyntaxException; @@ -259,6 +260,8 @@ public class HiveDatasetFinder implements IterableDatasetFinder<HiveDataset> { } return createHiveDataset(table, datasetConfig); + } catch (IllegalArgumentException e) { + Throwables.propagate(e); } catch (Throwable t) { log.error(String.format("Failed to create HiveDataset for table %s.%s", dbAndTable.getDb(), dbAndTable.getTable()), t);
