Hi guys,
This is great clarification!
An extended question from me is, what's the difference between
`state.checkpoints.dir` and the param you pass in to RocksDBStateBackend
constructor in`public RocksDBStateBackend(URI checkpointDataUri) throws
IOException`? They are really confusing.
I specified checkpointDataUri but got error of `CheckpointConfig says to
persist periodic checkpoints, but no checkpoint directory has been
configured. You can configure configure one via key
'state.checkpoints.dir'.`.
Thanks,
Bowen
--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050. n4.nabble.com/Clarification- on-state-backend-parameters- tp11419p13744.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
Free forum by Nabble | Edit this page |