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

server/2025/2/5 23:20:05/

当在提交一个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/server/165267.html

Python-基于PyQt5,wordcloud,pillow,numpy,os,sys的智能词云生成器

前言：日常生活中，我们有时后就会遇见这样的情形：我们需要将给定的数据进行可视化处理，同时保证呈现比较良好的量化效果。这时候我们可能就会用到词云图。词云图（Word cloud）又称文字云，是一种文…

深度学习探索：ChatGPT数据分析精髓梯度下降优化方法深度剖析

网罗开发 （小红书、快手、视频号同名） 大家好，我是展菲，目前在上市企业从事人工智能项目研发管理工作，平时热衷于分享各种编程领域的软硬技能知识以及前沿技术，包括iOS、前端、Harmony OS、Java、Python等…

MySQL数据库（二）- SQL

目录编辑一 DDL (一数据库操作 1 查询-数据库（所有/当前） 2 创建-数据库 3 删除-数据库 4 使用-数据库 (二表操作 1 创建-表结构 2 查询-所有表结构名称 3 查询-表结构内容 4 查询-建表语句 5 添加-字段名数据类型 6 修改-字段数据类…

mac 手工安装OpenSSL 3.4.0

如果你希望继续安装 openssl-3.4.0 而不是降级到 3.1.1，可以尝试以下解决方案。根据你提供的错误信息，问题可能出在测试阶段（make test），我们可以尝试跳过测试或修复测试失败的原因。 --- ### **解决方案&#xff1a…

《苍穹外卖》项目学习记录-Day7导入地址簿模块功能代码

一个用户可以有多个收货地址，但是只能有一个默认地址，这个默认地址的作用就是当用户下单的时候默认使用这个地址。用户也可以点击新增收货地址，在弹出来的页面可以填写一个新的地址，填写完后点击保存地址向数据库插入一条新增地址…

vue.js学习笔记

一、Vue概述通过我们学习的htmlcssjs已经能够开发美观的页面了，但是开发的效率还有待提高，那么如何提高呢？我们先来分析下页面的组成。一个完整的html页面包括了视图和数据，数据是通过请求从后台获取的，那么意味着我…

Node.js与嵌入式开发：打破界限的创新结合

文章目录一、Node.js的本质与核心优势1.1 什么是Node.js？1.2 嵌入式开发的范式转变二、Node.js与嵌入式结合的四大技术路径2.1 硬件交互层2.2 物联网协议栈2.3 边缘计算架构2.4 轻量化运行时方案三、实战案例：智能农业监测系统3.1 硬件配置3.2 软件架构3.3 核心代码片段四、…

使用 EXISTS 解决 SQL 中 IN 查询数量过多的问题

在 SQL 查询中，当我们面对需要在 IN 子句中列举大量数据的场景时，查询的性能往往会受到显著影响。这时候，使用 EXISTS 可以成为一种优化的良方。问题的来源假设我们有两个表，orders 和 customers，我们需要查询所有…

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

相关文章