Apache Flink 示例作业无法运行并显示“未找到作业”

Question

尝试运行在 flink 站点上找到的 SocketWindowWordCount 示例教程here。

我启动了 flink 集群，然后运行了一个本地套接字服务器：

nc -l 9000

编译取自github的示例源代码后，我运行该作业

flink run target/SocketWindowWordCount.jar  --port 9000

然后我向运行的终端输入一些单词nc。没有任何内容进入预期的输出文件，并且日志重复出现此错误：

2019-07-09 15:54:32,673 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler   - Exception occurred in REST handler: Job f9b3c58ca3026855fd2612e3c86551fa not found
2019-07-09 15:54:35,673 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler   - Exception occurred in REST handler: Job f9b3c58ca3026855fd2612e3c86551fa not found
2019-07-09 15:54:38,673 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler   - Exception occurred in REST handler: Job f9b3c58ca3026855fd2612e3c86551fa not found
2019-07-09 15:54:39,769 ERROR org.apache.flink.runtime.rest.handler.job.JobDetailsHandler   - Exception occurred in REST handler: Job f9b3c58ca3026855fd2612e3c86551fa not found

Answer 1

当您在浏览器中打开 Flink UI 选项卡时，通常会发生这种情况，该选项卡在之前的作业部署中保持打开状态。所以 UI 指向一个带有http://.../f9b3c58ca3026855fd2612e3c86551fa的 URL，这是一个不存在的 JobID。这会导致上面的日志出现。