public void stop()

in flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java [461:489]

• 25 lines of code
• 5 McCabe index (conditional complexity)

  public void stop() {
    // do not constrain close() calls with a timeout
    for (Entry<HiveEndPoint, HiveWriter> entry : allWriters.entrySet()) {
      try {
        HiveWriter w = entry.getValue();
        w.close();
      } catch (InterruptedException ex) {
        Thread.currentThread().interrupt();
      }
    }

    // shut down all thread pools
    callTimeoutPool.shutdown();
    try {
      while (callTimeoutPool.isTerminated() == false) {
        callTimeoutPool.awaitTermination(
              Math.max(DEFAULT_CALLTIMEOUT, callTimeout), TimeUnit.MILLISECONDS);
      }
    } catch (InterruptedException ex) {
      LOG.warn(getName() + ":Shutdown interrupted on " + callTimeoutPool, ex);
    }

    callTimeoutPool = null;
    allWriters.clear();
    allWriters = null;
    sinkCounter.stop();
    super.stop();
    LOG.info("Hive Sink {} stopped", getName() );
  }