李博帅的博客

2024-12-29发表2025-06-05更新大数据8 分钟读完 (大约1210个字)

Flink RocksDB状态反序列化问题及解决方案探讨

在实际进行Flink状态管理时，特别是结合RocksDB作为StateBackend并启用TTL(Time-To-Live)策略时，部分用户可能会遇到类似如下的报错提示：

2024-12-19发表2025-06-05更新大数据6 分钟读完 (大约899个字)

Flink本地Idea启动使用Rocksdb进行Checkpoint报错解决

在使用 Flink 与 RocksDB 进行状态管理时，可能会遇到如下异常报错：

Caused by: org.rocksdb.RocksDBException: Failed to create a NewWriteableFile: C:\Users\Administrator\AppData\Local\Temp\flink-io-xxxxxx\job_xxx\chk-2.tmp/MANIFEST-000004: 系统找不到指定的路径
    at org.rocksdb.Checkpoint.createCheckpoint(Native Method)
    at org.rocksdb.Checkpoint.createCheckpoint(Checkpoint.java:51)
    at org.apache.flink.contrib.streaming.state.snapshot.RocksIncrementalSnapshotStrategy.takeDBNativeCheckpoint(RocksIncrementalSnapshotStrategy.java:292)
    ...

错误信息提示 RocksDB 在创建写入文件时失败，原因是系统找不到指定的路径。该问题通常由 Flink 默认临时目录的路径不可写或路径不合法引起。

链接

分类

最新文章

标签