Package eu.stratosphere.nephele.managementgraph

Examples of eu.stratosphere.nephele.managementgraph.ManagementGraphIterator


      wrt.write("\"FAILED\": "+ jobmanager.getArchive().getJobTime(jobEvent.getJobID(), JobStatus.FAILED) + ",");
      wrt.write("\"CANCELED\": "+ jobmanager.getArchive().getJobTime(jobEvent.getJobID(), JobStatus.CANCELED) + ",");
      wrt.write("\"CREATED\": " + jobmanager.getArchive().getJobTime(jobEvent.getJobID(), JobStatus.CREATED)+",");

      if (jobEvent.getJobStatus() == JobStatus.FAILED) {
      ManagementGraphIterator managementGraphIterator =  new ManagementGraphIterator(jobManagementGraph,true);
      wrt.write("\"failednodes\": [");
      HashSet<String> map = new HashSet<String>();
      boolean first = true;
      while (managementGraphIterator.hasNext()) {
        ManagementVertex managementVertex = managementGraphIterator.next();
        String instanceName = managementVertex.getInstanceName();
        if (managementVertex.getExecutionState() == ExecutionState.FAILED && !map.contains(instanceName)) {
          if (first) {
            first = false;
          } else {
View Full Code Here

TOP

Related Classes of eu.stratosphere.nephele.managementgraph.ManagementGraphIterator

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.