Repository: incubator-gobblin Updated Branches: refs/heads/master d2e43542a -> 44738ed53
[GOBBLIN-280] Added new SpecCompiler compatible constructor to AzkabanSpecExecutor Closes #2133 from abti/service_azkaban_orchestrator Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/44738ed5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/44738ed5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/44738ed5 Branch: refs/heads/master Commit: 44738ed53815fa111667d1bf8046654625d69f88 Parents: d2e4354 Author: Abhishek Tiwari <[email protected]> Authored: Tue Oct 10 14:47:58 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Tue Oct 10 14:47:58 2017 -0700 ---------------------------------------------------------------------- .../service/modules/orchestration/AzkabanSpecExecutor.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/44738ed5/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanSpecExecutor.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanSpecExecutor.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanSpecExecutor.java index 2e06817..17470c7 100644 --- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanSpecExecutor.java +++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanSpecExecutor.java @@ -36,6 +36,10 @@ public class AzkabanSpecExecutor extends AbstractSpecExecutor { private SpecProducer<Spec> azkabanSpecProducer; + public AzkabanSpecExecutor(Config config) { + this(config, Optional.absent()); + } + public AzkabanSpecExecutor(Config config, Optional<Logger> log) { super(config, log); Config defaultConfig = ConfigFactory.load(ServiceAzkabanConfigKeys.DEFAULT_AZKABAN_PROJECT_CONFIG_FILE);
