Repository: falcon Updated Branches: refs/heads/master 2cc0438e9 -> 00a2b3a95
FALCON-2340 Passing groupid to oozie while scheduling the process Author: narayan-periwal <[email protected]> Reviewers: @pallavi-rao Closes #414 from nperiwal/master Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/00a2b3a9 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/00a2b3a9 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/00a2b3a9 Branch: refs/heads/master Commit: 00a2b3a95aee3fc68a8adf3f04c988df205fe4fe Parents: 2cc0438 Author: narayan-periwal <[email protected]> Authored: Thu Aug 9 16:00:36 2018 +0530 Committer: pallavi-rao <[email protected]> Committed: Thu Aug 9 16:00:36 2018 +0530 ---------------------------------------------------------------------- .../apache/falcon/workflow/engine/OozieWorkflowEngine.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/00a2b3a9/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java ---------------------------------------------------------------------- diff --git a/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java b/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java index a3b78e7..7098892 100644 --- a/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java +++ b/oozie/src/main/java/org/apache/falcon/workflow/engine/OozieWorkflowEngine.java @@ -153,6 +153,13 @@ public class OozieWorkflowEngine extends AbstractWorkflowEngine { if (StartupProperties.isServerInSafeMode()) { throwSafemodeException("SCHEDULE"); } + //Adding group information to pass to oozie + if (entity.getACL() != null && entity.getACL().getGroup() != null) { + if (suppliedProps == null) { + suppliedProps = new HashMap<>(); + } + suppliedProps.put(OozieClient.GROUP_NAME, entity.getACL().getGroup()); + } Map<String, BundleJob> bundleMap = findLatestBundle(entity); List<String> schedClusters = new ArrayList<String>(); for (Map.Entry<String, BundleJob> entry : bundleMap.entrySet()) { @@ -178,6 +185,7 @@ public class OozieWorkflowEngine extends AbstractWorkflowEngine { } //Do dryRun of coords before schedule as schedule is asynchronous + LOG.debug("The properties passed to oozie are: {}", properties.stringPropertyNames().toString()); dryRunInternal(cluster, new Path(properties.getProperty(OozieEntityBuilder.ENTITY_PATH)), skipDryRun); scheduleEntity(clusterName, properties, entity); }
