You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by ab...@apache.org on 2017/10/10 21:48:03 UTC
incubator-gobblin git commit: [GOBBLIN-280] Added new SpecCompiler
compatible constructor to AzkabanSpecExecutor
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 <ab...@gmail.com>
Authored: Tue Oct 10 14:47:58 2017 -0700
Committer: Abhishek Tiwari <ab...@gmail.com>
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);