Repository: incubator-gobblin Updated Branches: refs/heads/master 344d6d3c6 -> adc669fee
[GOBBLIN-247] Handled SqlException in validation job for avro-to-orc conversion Closes #2098 from aditya1105/avro2orc Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/adc669fe Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/adc669fe Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/adc669fe Branch: refs/heads/master Commit: adc669fee5d9550577779160eeffe61b19c8a692 Parents: 344d6d3 Author: aditya1105 <[email protected]> Authored: Mon Sep 11 02:09:26 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Mon Sep 11 02:09:26 2017 -0700 ---------------------------------------------------------------------- .../data/management/conversion/hive/validation/ValidationJob.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/adc669fe/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java index 9222d48..53805c8 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java @@ -594,7 +594,7 @@ public class ValidationJob extends AbstractJob { } } } catch (SQLException e) { - throw new RuntimeException(e); + log.warn("Execution failed for query set " + queries.toString(), e); } finally { try { closer.close();
