Apache Flink示例作业无法运行，显示“找不到作业”。

Question

我尝试运行在flink网站这里找到的SocketWindowWordCount示例教程。

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

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

- marathon

Answer 1

这通常发生在你的浏览器中打开了一个 Flink UI 标签，该标签是从以前的作业部署中未关闭的。因此，UI 指向一个 URL http://.../f9b3c58ca3026855fd2612e3c86551fa，它是一个不存在的 JobID，导致上面的日志出现。

- Rafi Aroch