Method run

src/org/apache/pig/backend/hadoop/PigJobControl.java:158–236

The main loop for the thread. The loop does the following: Check the states of the running jobs Update the states of waiting jobs Submit the jobs in ready state

()

   *    Submit the jobs in ready state
   */
  public void run() {
    if (!initSuccesful) {
      super.run();
      return;
    }
    try {
      setRunnerState(ThreadState.RUNNING);
      while (true) {
        while (getRunnerState() == ThreadState.SUSPENDED) {
          try {
            Thread.sleep(timeToSleep);
          }
          catch (Exception e) {
            //TODO the thread was interrupted, do something!!!
          }
        }

        synchronized(this) {
          Iterator<ControlledJob> it = getJobs(jobsInProgress).iterator();
          if (!it.hasNext()) {
              stop();
          }
          while(it.hasNext()) {
            ControlledJob j = it.next();

            // TODO: Need to re-visit the following try...catch
            // when Pig picks up a Hadoop release with MAPREDUCE-6762 applied
            // as its dependency.
            try {
              log.debug("Checking state of job " + j);
            } catch(NullPointerException npe) {
              log.warn("Failed to get job name " +
                "when checking state of job. " +
                "Check if job status is null.", npe);
            }

            switch(checkState(j)) {
            case SUCCESS:
              getJobs(successfulJobs).add(j);
              it.remove();
              break;
            case FAILED:
            case DEPENDENT_FAILED:
              getJobs(failedJobs).add(j);
              it.remove();
              break;
            case READY:
              submit(j);
              break;
            case RUNNING:
            case WAITING:
              //Do Nothing
              break;
            }
          }
        }

        if (getRunnerState() != ThreadState.RUNNING &&