Project

General

Profile

« Previous | Next » 

Revision 60356

Added by Claudio Atzori about 3 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
106 106 
					Properties properties = new Properties();
107 107 
					properties.load(IOUtils.toInputStream(currentAction.getData()));
108 108 
					properties.forEach((k, v) -> map.put(currentAction.getName() + ":" + k.toString(), v.toString()));
109 
					map.entrySet().forEach(e -> log.info(e.getKey() + " - " + e.getValue()));
110 109 
					log.info(String.format("found workflow action(%s) properties size %s", currentAction.getName(), properties.values().size()));
111 110 
				}
112 111 
			} else {
......
114 113 
			}
115 114 
		}
116 115 
		log.info(String.format("found workflow (%s) properties size %s", oozieJob.getAppName(), map.values().size()));
116 
		map.entrySet().forEach(e -> log.info(e.getKey() + " - " + e.getValue()));
117 117 
		return map;
118 118 
	}
119 119 

  		












Also available in:  Unified diff