Hi Sruthi,
Not possible out-of-the-box at the moment. You'll have to add the
RocksDB Flink dependency in flink_runner.gradle, e.g.:
compile "org.apache.flink:flink-statebackend-rocksdb_2.11:$flink_version"
Also in the Flink config you have to set
state.backend: rocksdb
Then you can run Nexmark against the cluster, e.g.
./gradlew :sdks:java:testing:nexmark:run \
-Pnexmark.runner=":runners:flink:1.10" \
-Pnexmark.args="
--runner=FlinkRunner
--flinkMaster=<flink_master:8081>
--streaming=true
--shutdownSourcesOnFinalWatermark=true
--query=12
--suite=SMOKE
--manageResources=false
--monitorJobs=true
--enforceEncodability=true
--enforceImmutability=true"
Admittedly, this is a bit complicated. We could make that easier without
much work.
Cheers,
Max
On 28.04.20 10:26, Sruthi Sree Kumar wrote:
> Hello,
>
> Is it possible to run the nexmark queries by specifying a
> state-backed(Ex: RocksDB) ?
>
>
> Regards,
> Sruthi
