code: @Override
    public void killTask(ExecutorDriver executorDriver, Protos.TaskID taskID) {
      final String taskId = taskID.getValue();
  
      LOG.info("Asked to kill task {}", taskId);
  
      KillState killState = monitor.requestKill(taskId);
  
      switch (killState) {
        case DIDNT_EXIST:
        case INCONSISTENT_STATE:
          LOG.warn("Couldn't kill task {} due to killState {}", taskId, killState);
          break;
        case DESTROYING_PROCESS:
        case INTERRUPTING_PRE_PROCESS:
        case KILLING_PROCESS:
          LOG.info("Requested kill of task {} with killState {}", taskId, killState);
          break;
      }
    }
docs: Invoked when a task running within this executor has been killed
  (via SchedulerDriver::killTask). Note that no status update will
  be sent on behalf of the executor, the executor is responsible
  for creating a new TaskStatus (i.e., with TASK_KILLED) and
  invoking ExecutorDriver::sendStatusUpdate.