flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java [731:740]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    });
    try {
      if (callTimeout > 0) {
        return future.get(callTimeout, TimeUnit.MILLISECONDS);
      } else {
        return future.get();
      }
    } catch (TimeoutException eT) {
      future.cancel(true);
      sinkCounter.incrementConnectionFailedCount();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java [430:440]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    });

    try {
      if (callTimeout > 0) {
        return future.get(callTimeout, TimeUnit.MILLISECONDS);
      } else {
        return future.get();
      }
    } catch (TimeoutException eT) {
      future.cancel(true);
      sinkCounter.incrementConnectionFailedCount();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -