asardaes/flink-rocksdb-ttl-test

Tested with Flink 1.14.4 and Scala 2.12. Jira ticket.

Copy misc/flink-conf.yaml to $FLINK_HOME/conf/ and start a local cluster with

$FLINK_HOME/bin/start-cluster.sh

Build this project with

./gradlew shadowJar

Execute Flink program with

$FLINK_HOME/bin/flink run -d build/libs/flink-rocksdb-ttl-test-0.0.0-SNAPSHOT-shadow.jar

Note the resulting job id and call (maybe with nohup)

misc/chkstat <JOB_ID> &

Results with 52ca77c

After running for 1.6 days.

Results with 67c76bb

After running for 2.3 days.

Results with c5dd5d2

After running for 3.5 days.