【Flink】【第9章】【 状态管理和容错机制】【02】CheckPoint和 状态后端_a)设置好checkpoint的保存路径 b)给每个算子设置唯一id c)把算子id和对应的算-CSDN博客网友收藏

【Flink】【第9章】【 状态管理和容错机制】【02】CheckPoint和 状态后端_a)设置好checkpoint的保存路径 b)给每个算子设置唯一id c)把算子id和对应的算-CSDN博客

文章浏览阅读2k次。状态管理状态后端1.状态的存储1.MemoryStateBackend2.FsStateBackend3.RocksDBBackend4.配置方式4.1 全局配置4.2 单任务配置2.状态的备份（checkpoint 和 savepoint）4.3 状态一致性4.3.1 flink状态的一致性级别4.3.2 端到端（end-to-end）......
2024-01-23 08:41 评论 0 阅读
阅读全文
windows中以本地模式运行spark遇到“Could not locate executable null\bin\winutils.exe in the Hadoop binarie”_本地运行flink could not locate executable null\bin\win-CSDN博客网友收藏

windows中以本地模式运行spark遇到“Could not locate executable null\bin\winutils.exe in the Hadoop binarie”_本地运行flink could not locate executable null\bin\win-CSDN博客

文章浏览阅读300次。1. 问题：2. 解决适用于win7、win10在windows环境下的eclipse或者idea中编写spark应用时，有时为了验证程序功能需要以本地模式运行测试。常常会遇到如下的异常：java.io.Exception: Could not locate executable null\bin\winutils.ex......
2024-01-24 00:21 评论 0 阅读
阅读全文
报错：Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSourceFactory_could not find a suitable table factory for 'org.a-CSDN博客网友收藏

报错：Could not find a suitable table factory for ‘org.apache.flink.table.factories.TableSourceFactory_could not find a suitable table factory for 'org.a-CSDN博客

文章浏览阅读4.4k次，点赞12次，收藏5次。重要错误提示：这是在提交yarn时报的错误，原因其实就是少了一些包，提交的集群后一些依赖包使用flink的lib目录下的，所以我需要将一些依赖包放到lib目录下。我们看到缺少的是org.apac......
2024-01-23 11:54 评论 0 阅读
阅读全文