java/kudu-client/src/test/java/org/apache/kudu/client/MiniKuduCluster.java
public void shutdown() {
    // Closing stdin should cause the control shell process to terminate.
    if (miniClusterStdin != null) {
      try {
        miniClusterStdin.close();
      } catch (IOException e) {
        LOG.info("Caught exception while closing minicluster stdin", e);
      }
    }
    if (miniClusterStdout != null) {
      try {
        miniClusterStdout.close();
      } catch (IOException e) {
        LOG.info("Caught exception while closing minicluster stdout", e);
      }
    }
    if (miniClusterErrorPrinter != null) {
      try {
        miniClusterErrorPrinter.join();
      } catch (InterruptedException e) {
        LOG.info("Caught exception while closing minicluster stderr", e);
      }
    }
    if (miniCluster != null) {
      try {
        miniCluster.waitFor();
      } catch (InterruptedException e) {
        LOG.warn("Minicluster process did not exit, destroying");
        miniCluster.destroy();
      }
    }
  }
/**
   * Shuts down a Kudu cluster.
   */
Shuts down a Kudu cluster.
Shuts down a Kudu cluster .
public void shutdown() {
    if (miniClusterStdin != null) {
      try {
        miniClusterStdin.close();
      } catch (IOException e) {
        LOG.info("Caught exception while closing minicluster stdin", e);
      }
    }
    if (miniClusterStdout != null) {
      try {
        miniClusterStdout.close();
      } catch (IOException e) {
        LOG.info("Caught exception while closing minicluster stdout", e);
      }
    }
    if (miniClusterErrorPrinter != null) {
      try {
        miniClusterErrorPrinter.join();
      } catch (InterruptedException e) {
        LOG.info("Caught exception while closing minicluster stderr", e);
      }
    }
    if (miniCluster != null) {
      try {
        miniCluster.waitFor();
      } catch (InterruptedException e) {
        LOG.warn("Minicluster process did not exit, destroying");
        miniCluster.destroy();
      }
    }
  }
public void shutdown ( ) { if ( miniClusterStdin != null ) { try { miniClusterStdin . close ( ) ; } catch ( IOException e ) { LOG . info ( "Caught exception while closing minicluster stdin" , e ) ; } } if ( miniClusterStdout != null ) { try { miniClusterStdout . close ( ) ; } catch ( IOException e ) { LOG . info ( "Caught exception while closing minicluster stdout" , e ) ; } } if ( miniClusterErrorPrinter != null ) { try { miniClusterErrorPrinter . join ( ) ; } catch ( InterruptedException e ) { LOG . info ( "Caught exception while closing minicluster stderr" , e ) ; } } if ( miniCluster != null ) { try { miniCluster . waitFor ( ) ; } catch ( InterruptedException e ) { LOG . warn ( "Minicluster process did not exit, destroying" ) ; miniCluster . destroy ( ) ; } } }
Shuts down a Kudu cluster.
Shuts down a Kudu cluster .
// Closing stdin should cause the control shell process to terminate.