scala - Flink-1.4.2 出现错误：对象 contrib 不是包 org.apache.flink 的成员

Question

我正在使用flink-1.4.2并尝试使用RocksDBStateBackend. 导入时org.apache.flink.contrib.streaming.state.RocksDBStateBackend。

我收到此错误：

contrib 不是包 org.apache.flink 的成员

标签： scalaapache-flink

Answer 1

没有更多信息，我只猜你没有在你的 pom 中包含 RocksDb 依赖项

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-statebackend-rocksdb_2.11</artifactId>
        <version>${flink.version}</version>
    </dependency>