正在尝试运行flink站点上的socketwindowwordcount示例教程。
我启动了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
1条答案
按热度按时间xtupzzrd1#
这种情况通常发生在浏览器中打开FlinkUI选项卡时，该选项卡在以前的作业部署中保持打开状态。所以ui指向一个urlhttp://.../f9b3c58ca3026855fd2612e3c86551fa 这是一个不存在的jobid。这会导致显示上面的日志。