我尝试运行在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