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

devtools/2025/2/4 17:25:41/

当在提交一个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

分发一下即可

xsync.sh /home/wc.txt

http://www.ppmy.cn/devtools/156059.html

基于微信小程序的新闻资讯系统设计与实现（LW+源码+讲解）

专注于大学生项目实战开发,讲解,毕业答疑辅导，欢迎高校老师/同行前辈交流合作✌。技术范围：SpringBoot、Vue、SSM、HLMT、小程序、Jsp、PHP、Nodejs、Python、爬虫、数据可视化、安卓app、大数据、物联网、机器学习等设计与开发。主要内容：…

Java篇之继承

目录一. 继承 1. 为什么需要继承 2. 继承的概念 3. 继承的语法 4. 访问父类成员 4.1 子类中访问父类的成员变量 4.2 子类中访问父类的成员方法 5. super关键字 6. super和this关键字 7. 子类构造方法 8. 代码块的执行顺序 9. protected访问修饰限定符 10. 继承方式…

MySQL（3）

约束概述约束演示外键约束概念：约束是作用在表中字段上的规则，用于限制存储在表中的数据目的：保证数据库中数据的正确，有效性和完整性 not null 非空约束 unique 唯一约束 primary key 主键约束主键是一行数据的唯一…

使用 Docker + Nginx + Certbot 实现自动化管理 SSL 证书

使用 Docker Nginx Certbot 实现自动化管理 SSL 证书在互联网安全环境日益重要的今天，为站点或应用部署 HTTPS 已经成为一种常态。然而，手动申请并续期证书既繁琐又容易出错。本文将以 Nginx Certbot 为示例，基于 Docker 容器来搭建一个…

2025_2_3 C语言中关于枚举类型，动态内存分配

1.枚举类型枚举类型是用来表示一些离散值的枚举常量默认从0开始，依次递增1 typedef enum{s1,s2,s3,s4 }num;以上：s10,s2 1, s3 2, s4 3 可以为枚举常量显式指定值 typedef enum{s1 1,s2 2,s3 3,s4 4 }num;枚举常量的调用有两种方法直接使用…

15 刚体变换模块（rigid.rs）

rigid.rs是一个表示三维刚体变换（Rigid Transformation）的结构体定义，用于在计算机图形学、机器人学以及物理模拟等领域中表示物体在三维空间中的旋转和平移。在这个定义中，所有长度在变换后都保持不变，这是刚体变换的…

Qt文件操作

目录一、文件操作相关类 1.QFile 2.QFileInfo 3.QTextStream 4.QDataStream 5.QDir 6.QFileSystemWatcher 7.QTemporaryFile 二、文件操作示例 1.文本文件操作 2.目录操作 3.二进制文件操作一、文件操作相关类 1.QFile QFile类用于文件的创建、读写、复制、删除…

Python面试宝典13 | Python 变量作用域，从入门到精通

今天，我们来深入探讨一下 Python 中一个非常重要的概念——变量作用域。理解变量作用域对于编写清晰、可维护、无 bug 的代码至关重要。什么是变量作用域？ 简单来说，变量作用域就是指一个变量在程序中可以被访问的范围。Python 中有四种作…

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

相关文章