Можно ли использовать Riak CS с Apache Flink?
Я хочу настроитьfilesystem
государственный бэкэнд иzookeeper
режим восстановления:
state.backend: filesystem
state.backend.fs.checkpointdir: ???
recovery.mode: zookeeper
recovery.zookeeper.storageDir: ???
Как видите, я должен указатьcheckpointdir
а такжеstorageDir
параметров, но у меня нет файловых систем, поддерживаемых Apache Flink (например, HDFS или Amazon S3). Но я установил кластер Riak CS (кажется, этосовместим с S3).
Итак, могу ли я использовать Riak CS вместе с Apache Flink? Если это возможно: как настроить Apache Flink для работы с Riak CS?