开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC我加上rocksdb了依赖,启动报错,还需要这个动态库什么鬼?

Flink CDC我加上rocksdb了依赖,启动报错,还需要这个动态库什么鬼?image.png
image.png

展开
收起
真的很搞笑 2023-11-01 14:44:18 333 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    抱歉给您带来了麻烦!加入 RocksDB 相关依赖之后,除了确保 RocksDB 已经安装,还要确保存储路径中的 RocksDB 动态库文件存在。如果缺失,您需要下载 RocksDB 并添加到 Flink 的 lib 路径下,确保 Flink 可以访问这些动态链接库。
    在 Windows 系统上,可以在如下目录下找到 RocksDB 动态链接库:

    rocksdbjni.dll
    librocksdbjni.dll.a
    librocksdbjni.dll.so
    

    而在 Linux 系统上,需要 RocksDB 二进制包中的动态链接库文件,例如:

    librocksdbjni.so
    libsnappy.so.1
    libbz2.so.1.0
    liblz4.so.1.7
    libzstd.so.1.4.4
    libgflags.so.2
    
    2023-11-02 14:59:41
    赞同 1 展开评论 打赏
  • Flink CDC在使用RocksDB作为状态后端时,确实需要相关的依赖。但仅仅添加了依赖可能还不够,您还需要确保动态库文件在类路径中。关于这个问题,可能需要检查以下几个方面:

    1. 确保所有必需的依赖都已添加到项目中。对于Flink CDC和RocksDB,这可能涉及到flink-connector-rocksdb和flink-sql-connector-cdc等JAR包。

    2. 检查项目类路径(Classpath)是否正确设置,确保所有依赖的JAR包都可以被正确加载。

    3. 某些情况下,除了添加JAR包外,可能还需要将RocksDB的动态库文件(例如librocksdbjni.so或librocksdb.so)放置在正确的位置,以便Flink可以正确地找到并使用它。

    2023-11-02 14:45:45
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载