Hi on 2019/9/3 12:14, 々守护々 wrote:
现象:我是在代码中配置StateBackend的,代码是这样写的env.setStateBackend(new RocksDBStateBackend("hdfs://host51:9000/flink/checkpoints",true)),但是我发现在下面的SQLwindow中始终在checkpoint那就过不去,总是报n/a,下面我就把代码中的这句给注释掉了,在flink-conf.xml文件中配置 state.checkpoints.dir: hdfs://host51:9000/flink/flink-checkpoints这样就能正常执行, 请问SQLwindow和RocksDBStateBackend有什么冲突吗,上面的原因是什么?
It seems like a filesystem issue, though I have no experience on it too. regards.