开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink1.16.0,sql-client客户端,报这个错,请问这个是什么问题啊?

flink1.16.0,sql-client客户端,yarn-session下运行,报这个错,请问大佬这个是什么问题啊?怎么解决?684749cb4362a655b82935eebe3ceffb.png
3ec4561cc4b20d045a3bd5b18d293cd8.png

展开
收起
真的很搞笑 2023-11-06 12:03:20 69 0
1 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    这个错误是由于在Flink 1.16.0版本中,org.apache.flink.table.client.YarnSessionClient类中的main方法中,使用了java.lang.LangExecutionException来捕获所有未捕获的异常。但是,这个异常已经被org.apache.flink.util打印为YarnException,导致多余的异常打印。
    解决这个问题的方法是修改org.apache.flink.table.client.YarnSessionClient类中的main方法,使其不再使用java.lang.LangExecutionException来捕获异常,而是直接使用org.apache.flink.util.YarnException来捕获异常。这样可以避免多余的异常打印,并且可以更准确地捕获到运行时出现的异常。具体的修改代码如下:

    public static void main(String[] args) {
        try {
            YarnSessionClient client = YarnSessionClient.create("test");
            client.connect();
            // ...
        } catch (YarnException e) {
            // Print the exception and exit.
            e.printStackTrace();
            System.exit(1);
        }
    }
    
    2023-11-06 13:40:50
    赞同 1 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    SQL Server在电子商务中的应用与实践 立即下载
    GeoMesa on Spark SQL 立即下载
    原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载