Project

General

Profile

« Previous | Next » 

Revision 60354

Added by Claudio Atzori about 2 years ago

catch output params from the different oozie workflow actions

View differences:

modules/dnet-hadoop-service/trunk/src/main/java/eu/dnetlib/data/hadoop/oozie/OozieJobMonitor.java
99 99 
	 * Provides report entries when found for given oozie job identifier. Returns null when report not found.
100 100 
	 */
101 101 
	private static Properties getReport(final OozieClient oozieClient, final String oozieJobId, final Set<String> workflowActions) throws OozieClientException, IOException {
102 
		Properties properties = new Properties();
102 103 
		WorkflowJob oozieJob = oozieClient.getJobInfo(oozieJobId);
103 
		Properties properties = new Properties();
104 104 
		for (WorkflowAction currentAction : oozieJob.getActions()) {
105 105 
			log.info(String.format("looking for workflow actions to report, current: '%s'", currentAction.getName()));
106 106 
			if (workflowActions.contains(currentAction.getName())) {
......
114 114 
				} else if (StringUtils.isNotBlank(currentAction.getData())) {
115 115 
					properties.load(IOUtils.toInputStream(currentAction.getData()));
116 116 
					log.info(String.format("found workflow action(%s) properties size %s", currentAction.getName(), properties.values().size()));
117 
					return properties;
118 117 
				}
119 118 
			} else {
120 119 
				log.info(String.format("cannot find workflow action(%s) properties", currentAction.getName()));

Also available in: Unified diff