Hi,
had the same problem.
Try this:
env.setStateBackend((StateBackend) new
FsStateBackend("hdfs://namenode:40010/flink/checkpoints"));yeah... not the cleanest way... I guess the API is not that clean after all. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
