flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Wesley Peng <weslep...@gmail.com>
Subject Re: flink使用StateBackend问题
Date Tue, 03 Sep 2019 07:24:54 GMT
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.

Mime
View raw message