Ich möchte @ konfigurierfilesystem State Backend undzookeeper Wiederherstellungsmodus

state.backend: filesystem
state.backend.fs.checkpointdir: ???

recovery.mode: zookeeper
recovery.zookeeper.storageDir: ???

Wie Sie sehen, sollte ich @ angebcheckpointdir undstorageDir parameter, aber ich habe keine Dateisysteme, die von Apache Flink unterstützt werden (wie HDFS oder Amazon S3). Aber ich habe Riak CS Cluster installiert (scheint eskompatibel mit S3).

Also, kann ich Riak CS zusammen mit Apache Flink verwenden? Wenn es möglich ist: Wie konfiguriere ich Apache Flink für Riak CS?