Можно ли использовать 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?

Ответы на вопрос(1)

Ваш ответ на вопрос