@Override
    public void taskKilled(TezTaskAttemptID taskAttemptId) {
      try {
        sendOrQueueEvent(ReaderEvent.errorEvent(
            "Received task killed event for task ID " + taskAttemptId));
      } catch (Exception err) {
        LOG.error("Error during heartbeat responder:", err);
      }
    }
Close all outstanding connections created by getSplits() calls
llap-ext-client/src/java/org/apache/hadoop/hive/llap/LlapBaseInputFormat.java