Examples of org.apache.tez.client.TezSession.stop()

org.apache.tez.client.TezSession.stop()
Shutdown a Tez Session. @throws TezException @throws IOException

        }
      }
      dagStatus = dagClient.getDAGStatus(null);
    }
    if (dagViaRPC && !reuseSession) {
      tezSession.stop();
    }
    return dagStatus.getState();
  }


  private static LocalResource createLocalResource(FileSystem fc, Path file,

View Full Code Here

          System.exit(-1);
        }
      }
    } finally {
      fs.delete(stagingDir, true);
      tezSession.stop();
    }


    ExampleDriver.printDAGStatus(dagClient, vNames);
    LOG.info("Application completed. " + "FinalState=" + dagStatus.getState());
    System.exit(dagStatus.getState() == DAGStatus.State.SUCCEEDED ? 0 : 1);

View Full Code Here

            + "FinalState=" + dagStatus.getState());
      }
    } finally {
      fs.delete(stagingDir, true);
      if (useTezSession) {
        tezSession.stop();
      }
    }


    if (!useTezSession) {
      ExampleDriver.printDAGStatus(dagClient, vNames);

View Full Code Here

          continue;
        }
        YarnApplicationState appState = appReport.getYarnApplicationState();
        if (!sentKillSession) {
          if (appState == YarnApplicationState.RUNNING) {
            tezSession.stop();
            sentKillSession = true;
          }
        } else {
          if (appState == YarnApplicationState.FINISHED
              || appState == YarnApplicationState.KILLED

View Full Code Here

      Thread.sleep(500l);
      if(killDagWhileRunning
          && dagStatus.getState() == DAGStatus.State.RUNNING) {
        LOG.info("Killing running dag/session");
        if (dagViaRPC) {
          tezSession.stop();
        } else {
          dagClient.tryKillDAG();
        }
      }
      dagStatus = dagClient.getDAGStatus(null);

View Full Code Here

        }
      }
      dagStatus = dagClient.getDAGStatus(null);
    }
    if (dagViaRPC && !reuseSession) {
      tezSession.stop();
    }
    return dagStatus.getState();
  }


  private static LocalResource createLocalResource(FileSystem fc, Path file,

View Full Code Here

      dagStatus = dagClient.getDAGStatus(Sets.newHashSet(StatusGetOpts.GET_COUNTERS));
      counters = dagStatus.getDAGCounters();
      
    } finally {
      fs.delete(stagingDir, true);
      tezSession.stop();
    }


    ExampleDriver.printDAGStatus(dagClient, vNames, true, true);
    LOG.info("Application completed. " + "FinalState=" + dagStatus.getState());
    errorCode = (dagStatus.getState() == DAGStatus.State.SUCCEEDED ? 0 : 1);

View Full Code Here

          return false;
        }
        return true;
    } finally {
      fs.delete(stagingDir, true);
      tezSession.stop();
    }
  }


  public static void main(String[] args) throws Exception {
    Configuration conf = new Configuration();

View Full Code Here

          return false;
        }
        return true;
    } finally {
      fs.delete(stagingDir, true);
      tezSession.stop();
    }
  }


  public static void main(String[] args) throws Exception {
    if ((args.length%2) != 0) {

View Full Code Here

      if (!retainStagingDir) {
        pathFs.delete(stagingDir, true);
      }
      if (useTezSession) {
        LOG.info("Shutting down session");
        tezSession.stop();
      }
    }


    if (!useTezSession) {
      ExampleDriver.printDAGStatus(dagClient, vNames);

View Full Code Here

0 1 2

TOP

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.