本文整理了Java中org.apache.flink.runtime.execution.Environment.failExternally()方法的一些代码示例，展示了Environment.failExternally()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Environment.failExternally()方法的具体详情如下：
包路径：org.apache.flink.runtime.execution.Environment
类名称：Environment
方法名：failExternally

Environment.failExternally介绍

[英]Marks task execution failed for an external reason (a reason other than the task code itself throwing an exception). If the task is already in a terminal state (such as FINISHED, CANCELED, FAILED), or if the task is already canceling this does nothing. Otherwise it sets the state to FAILED, and, if the invokable code is running, starts an asynchronous thread that aborts that code.

This method never blocks.
[中]标记由于外部原因（任务代码本身引发异常以外的原因）导致任务执行失败。如果任务已处于终端状态（如已完成、已取消、已失败），或者如果任务已取消，则此操作不会执行任何操作。否则，它会将状态设置为FAILED，如果可调用代码正在运行，则启动一个异步线程中止该代码。
这种方法永远不会阻塞。

代码示例

代码示例来源：origin: apache/flink

/**
 * Handles an exception thrown by another thread (e.g. a TriggerTask),
 * other than the one executing the main task by failing the task entirely.
 *
 * <p>In more detail, it marks task execution failed for an external reason
 * (a reason other than the task code itself throwing an exception). If the task
 * is already in a terminal state (such as FINISHED, CANCELED, FAILED), or if the
 * task is already canceling this does nothing. Otherwise it sets the state to
 * FAILED, and, if the invokable code is running, starts an asynchronous thread
 * that aborts that code.
 *
 * <p>This method never blocks.
 */
@Override
public void handleAsyncException(String message, Throwable exception) {
  if (isRunning) {
    // only fail if the task is still running
    getEnvironment().failExternally(exception);
  }
}

代码示例来源：origin: apache/flink

@Override
  public void failOperator(Throwable throwable) {
    getContainingTask().getEnvironment().failExternally(throwable);
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.10

/**
 * Handles an exception thrown by another thread (e.g. a TriggerTask),
 * other than the one executing the main task by failing the task entirely.
 *
 * <p>In more detail, it marks task execution failed for an external reason
 * (a reason other than the task code itself throwing an exception). If the task
 * is already in a terminal state (such as FINISHED, CANCELED, FAILED), or if the
 * task is already canceling this does nothing. Otherwise it sets the state to
 * FAILED, and, if the invokable code is running, starts an asynchronous thread
 * that aborts that code.
 *
 * <p>This method never blocks.
 */
@Override
public void handleAsyncException(String message, Throwable exception) {
  if (isRunning) {
    // only fail if the task is still running
    getEnvironment().failExternally(exception);
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

/**
 * Handles an exception thrown by another thread (e.g. a TriggerTask),
 * other than the one executing the main task by failing the task entirely.
 *
 * <p>In more detail, it marks task execution failed for an external reason
 * (a reason other than the task code itself throwing an exception). If the task
 * is already in a terminal state (such as FINISHED, CANCELED, FAILED), or if the
 * task is already canceling this does nothing. Otherwise it sets the state to
 * FAILED, and, if the invokable code is running, starts an asynchronous thread
 * that aborts that code.
 *
 * <p>This method never blocks.
 */
@Override
public void handleAsyncException(String message, Throwable exception) {
  if (isRunning) {
    // only fail if the task is still running
    getEnvironment().failExternally(exception);
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java

/**
 * Handles an exception thrown by another thread (e.g. a TriggerTask),
 * other than the one executing the main task by failing the task entirely.
 *
 * <p>In more detail, it marks task execution failed for an external reason
 * (a reason other than the task code itself throwing an exception). If the task
 * is already in a terminal state (such as FINISHED, CANCELED, FAILED), or if the
 * task is already canceling this does nothing. Otherwise it sets the state to
 * FAILED, and, if the invokable code is running, starts an asynchronous thread
 * that aborts that code.
 *
 * <p>This method never blocks.
 */
@Override
public void handleAsyncException(String message, Throwable exception) {
  if (isRunning) {
    // only fail if the task is still running
    getEnvironment().failExternally(exception);
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

@Override
  public void failOperator(Throwable throwable) {
    getContainingTask().getEnvironment().failExternally(throwable);
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java

@Override
  public void failOperator(Throwable throwable) {
    getContainingTask().getEnvironment().failExternally(throwable);
  }
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.10

@Override
  public void failOperator(Throwable throwable) {
    getContainingTask().getEnvironment().failExternally(throwable);
  }
}