欢迎来到尧图网

您的位置：首页 > 新闻 > 资讯 > Flink报错Caused by: java.io.FileNotFoundException: /home/wc.txt

Flink报错Caused by: java.io.FileNotFoundException: /home/wc.txt

2025/2/8 2:28:54 来源：https://blog.csdn.net/m0_57764570/article/details/145412808 浏览: 次关键词：Flink报错Caused by: java.io.FileNotFoundException: /home/wc.txt

当在提交一个flink任务报如下的错误时：

Caused by: java.io.FileNotFoundException: /home/wc.txt (没有那个文件或目录)at java.io.FileInputStream.open0(Native Method)at java.io.FileInputStream.open(FileInputStream.java:195)at java.io.FileInputStream.<init>(FileInputStream.java:138)at org.apache.flink.core.fs.local.LocalDataInputStream.<init>(LocalDataInputStream.java:50)at org.apache.flink.core.fs.local.LocalFileSystem.open(LocalFileSystem.java:134)at org.apache.flink.api.common.io.FileInputFormat$InputSplitOpenThread.run(FileInputFormat.java:1053)

原因是：你的 taskManager 有三台，你的数据只在本地存放一份，所以需要将数据分发给 bigdata02 和 bigdata03

分发一下即可