Package com.twitter.ambrose.hive.reporter

Examples of com.twitter.ambrose.hive.reporter.EmbeddedAmbroseHiveProgressReporter.pushEvent()

107
108
109
110
111
112
113
114
115
116
117
    // a job has been started
    if (job.getId() == null) {
      // job identifier on GUI
      job.setId(AmbroseHiveUtil.asDisplayId(queryId, jobIDStr, nodeId));
      reporter.addJobIdToNodeId(jobIDStr, nodeId);
      reporter.pushEvent(queryId, new Event.JobStartedEvent(dagNode));
    }
    try {
     
      boolean isUpdated = updateJobState();
      if (isUpdated && !reporter.getCompletedJobIds().contains(jobIDStr)) {
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
        else {
          event = new Event.JobProgressEvent(dagNode);
        }
        reporter.addJobIdToProgress(jobIDStr, getJobProgress());
        pushWorkflowProgress(queryId, reporter);
        reporter.pushEvent(queryId, event);
      }
    }
    catch (IOException e) {
      LOG.error("Error getting job info!", e);
    }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
        HiveJob job = (HiveJob) dagNode.getJob();
        job.setConfiguration(allConfProps);
        MapReduceJobState mrJobState = getJobState(job);
        mrJobState.setSuccessful(false);
        reporter.addJob((Job) job);
        reporter.pushEvent(queryId, new Event.JobFailedEvent(dagNode));
      }
    }

    reporter.restoreEventStack();
    String sleepTime = System.getProperty(POST_SCRIPT_SLEEP_SECS_PARAM, "10");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.