Apache Livy：如何自动使 RSCDriver 失败？

问题描述

我正在研究一个用例，如果会话中的任何语句失败，我想使交互式 Livy 会话的 Yarn 应用程序失败。我的问题是如何在停止 sparkContext 后自动使 RSCDriver 失败？

我尝试在 Netty 的处理程序方法内的 RSCDriver.java 中抛出异常，如下所示：

public void handle(ChannelHandlerContext ctx,EndSession msg) throws Exception {
  if (livyConf.getBoolean(TEST_STUCK_END_SESSION)) {
    LOG.warn("Ignoring EndSession request because TEST_STUCK_END_SESSION is set.");
  } else {
    LOG.debug("Shutting down due to EndSession request.");
    // shutdown();
    throw new Exception("This is a test exception.");
  }
}

但 Yarn 应用程序只是停留在 RUNNING 状态，尽管我在 Livy 日志中看到了这个异常。有没有办法让 Yarn 应用程序因这个异常而失败？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）