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.

Reply via email to