感谢! flink1.11.1版本里面,我尝试了下面两种backend,目前运行了20多个小时, 能够看到状态的大小在一个区间内波动,没有发现一直增长的情况了。 StateBackend backend =new RocksDBStateBackend("hdfs:///checkpoints-data/"+yamlReader.getValueByKey("jobName").toString()+"/",false); StateBackend backend =new FsStateBackend("hdfs:///checkpoints-data/"+yamlReader.getValueByKey("jobName").toString()+"/",false);
这样看,有可能是RocksDBStateBackend增量模式这边可能存在一些问题。 RocksDBStateBackend: <http://apache-flink.147419.n8.nabble.com/file/t793/444.png> FsStateBackend: <http://apache-flink.147419.n8.nabble.com/file/t793/555.png> -- Sent from: http://apache-flink.147419.n8.nabble.com/