É possível usar o Riak CS com o Apache Flink?
Eu quero configurarfilesystem
back-end do estado ezookeeper
modo de recuperação:
state.backend: filesystem
state.backend.fs.checkpointdir: ???
recovery.mode: zookeeper
recovery.zookeeper.storageDir: ???
Como você pode ver, eu devo especificarcheckpointdir
estorageDir
parâmetros, mas não tenho sistemas de arquivos suportados pelo Apache Flink (como HDFS ou Amazon S3). Mas eu instalei o cluster Riak CS (parece quecompatível com S3)
Então, posso usar o Riak CS junto com o Apache Flink? Se for possível: como configurar o Apache Flink para funcionar com o Riak CS?