Search code examples
scalaapache-flink

Flink-1.4.2 Getting Error: object contrib is not a member of package org.apache.flink


I am using flink-1.4.2 and trying to use RocksDBStateBackend. While importing org.apache.flink.contrib.streaming.state.RocksDBStateBackend.

I am getting this error:

contrib is not a member of package org.apache.flink


Solution

  • Without more information I only guess you haven't included the RocksDb dependency in your pom

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