Hi,
I tried to use the newly-supported RocksDB backend (Flink 1.1.4) on my Windows
laptop.
However, it is not creating any state and is throwing NPE while trying to call:
org.apache.flink.streaming.util.HDFSCopyFromLocal$1.run(HDFSCopyFromLocal.java:47)
which eventually gets down to not finding Hadoop Winutils.
I am not using an hdfs path....
String statepath = parameterTool.get("statepath",
"file:///c:/temp/flink/checkpoints<file:///c:\temp\flink\checkpoints>");
env.setStateBackend(new RocksDBStateBackend(statepath));
I notice that in v1.2.0 the async checkpoint mode has been removed
(https://issues.apache.org/jira/browse/FLINK-4340)
In the interim is there any hint to using RocksDB on Windows, or should I just
revert to File for my playground?
Cheers
Dave Torok
