至此y 2021-12-15 18:57 采纳率: 100%
浏览 22
已结题

flink跑jar，需要读取csv文件

flink跑jar时，这里面的主类读取路径下的csv文件装载到mysql中。这个不知道怎么搞怎么搞！

img

  • 写回答

1条回答 默认 最新

  • 三千烦恼丝xzh 2021-12-15 19:04
    关注

    异常描述的很清楚，文件不存在或者flink没有读取权限

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题？

  • flink运行jar时找不到配置文件
    2023-03-17 09:58
    开心编码的博客 flink任务通过读取配置的方式来运行程序，写好一个模板每次只需要通过修改配置文件重新压缩成jar之后即可。一定要配置resources目录，不然的话程序在flink中找不到properties文件。
  • Flink实战-实时读取日志文件和kafka，持续统计TOP10热门商品
    2021-01-01 23:23
    马飞的博客 从日志中读取数据做一些统计聚合，最终把想要的数据输出，基本是每个公司都会有的场景，比如用户分析，商品分析，实时大屏等等，我们最早的做法是全部读出来，写到redis或者es去，然后web端再去实时查询统计，其实有...
  • 使用flinksql读取parquent文件
    2021-06-08 20:36
    大数据面壁者的博客 使用flinksql读取parquent文件 一、导入maven依赖 <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-parquet_2.12</artifactId> <version>1.11</...
  • flink-1.14.4 安装包 scala 2.12
    2022-04-03 00:37
    3. **编写作业**: 使用 Scala API 编写 Flink 流处理作业，例如读取数据源、应用转换和定义输出。以下是一个简单的 WordCount 示例： ```scala import org.apache.flink.streaming.api.scala._ val env = ...
  • flink读取不到文件_Flink开发遇到的问题汇总-
    2021-01-17 17:50
    MetaD的博客 1，提交的离线任务完成之后，在一段时间后web端没有显示或者说自动消失： 原因分析：https://blog.csdn.net/u013076044/article/details/104740792是需要开启historyserver2，Flink读取hdfs的(hive分区)文件，目前...
  • Flink依赖配置
    2024-03-12 13:25
    quant_Amy的博客 在Maven项目的pom.xml中添加。 读取CSV文件依赖 org.apache.flink flink-csv 1.13.0
  • 大数据学习-Flink
    2024-06-12 21:56
    @追求的博客 1、将任务提交到yarn上运行，yarn会为每一个flink地任务启动一个jobmanager和一个或者多个taskmanasger。可以定时将flink计算的状态持久化到hdfs中，如果任务执行失败，可以基于hdfs中保存到的状态恢复任务，保证...
  • FlinkParquet:使用Parquet文件格式（使用Avro）通过Apache Flink处理数据
    2021-05-15 17:25
    使用Apache Flink处理Apache Parquet文件此仓库包含用于设置Flink数据流以处理Parquet文件的示例代码。 resources/下的CSV数据集是从下载的Restaurant Score数据集。 有关更多信息，请参见。 ###生成Avro模型类如果...
  • flink 1.10 Sql方式 读取kafka
    2020-11-04 16:53
    BitData_的博客 "flink-kafka") ).withFormat( // new Json().failOnMissingField(false) new Csv().ignoreParseErrors().fieldDelimiter(',') ).withSchema( new Schema() .field("id", DataTypes.STRING()).field("age", Data...
  • 大数据领域Flink的状态管理最佳实践
    2025-12-15 00:35
    AI软件工程实践的博客 在流式处理领域，状态是Flink区别于其他框架的核心竞争力——它让流式应用能实现“记忆”（比如计算用户累计消费、实时去重、窗口聚合）。状态不一致：故障恢复后数据计算错误；性能瓶颈：Checkpoint超时、状态后端...
  • 没有解决我的问题, 去提问

问题事件

  • 系统已结题 5月16日
  • 已采纳回答 5月8日
  • 创建了问题 12月15日