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 2018/03/21 08:31:05 UTC
[47/50] incubator-gobblin git commit: [GOBBLIN-426] Change signature
of AzkabanJobLauncher.initJobListener()[]
[GOBBLIN-426] Change signature of AzkabanJobLauncher.initJobListener()[]
Closes #2303 from epattuk/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/2e61a10a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/2e61a10a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/2e61a10a
Branch: refs/heads/0.12.0
Commit: 2e61a10ac799d2bafe57a2162eafbbed19c91546
Parents: 1ddaffa
Author: Erman Pattuk <ep...@epattuk-ld1.linkedin.biz>
Authored: Tue Mar 13 11:14:41 2018 -0700
Committer: Hung Tran <hu...@linkedin.com>
Committed: Tue Mar 13 11:14:41 2018 -0700
----------------------------------------------------------------------
.../main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2e61a10a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java
index 2a7d311..c78d098 100644
--- a/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java
+++ b/gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java
@@ -224,7 +224,7 @@ public class AzkabanJobLauncher extends AbstractJob implements ApplicationLaunch
this.closer.register(new ServiceBasedAppLauncher(jobProps, "Azkaban-" + UUID.randomUUID()));
}
- private JobListener initJobListener() {
+ protected JobListener initJobListener() {
CompositeJobListener compositeJobListener = new CompositeJobListener();
List<String> listeners = new State(props).getPropAsList(GOBBLIN_CUSTOM_JOB_LISTENERS, EmailNotificationJobListener.class.getSimpleName());
try {