Flink(scala版)本地运行踩坑记录(java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobE)

背景

  • 学习过程中,本地首次运行流处理模式的wordCount失败

异常信息

在这里插入图片描述

本地参数配置

  • 代码

    //从外部命令中提取参数,作为socket主机名和端口号
    val paramTool: ParameterTool = ParameterTool.fromArgs(args)
    val host: String = paramTool.get("host")
    val port: Int = paramTool.getInt("port")
    //接收一个socket文本流
    val inputDataStream: DataStream[String] = env.socketTextStream(host,port)
  • 代码中采用的是socket文本流,所以做了host和port配置
    在这里插入图片描述

查看本地进程

在这里插入图片描述
综上经过多次试验后证明抛此异常原因是没有先启动socket,在终端中打开socket监听在重新运行代码就可以了

在这里插入图片描述

版权声明：本文为qq_41999004原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。