提交 b17632dd 编写于 作者: G Gyula Fora

[FLINK-3354] Determine correct size for RocksDB snapshots

Closes #1638
上级 73bc35f1
......@@ -421,7 +421,8 @@ public abstract class AbstractRocksDBState<K, N, S extends State, SD extends Sta
@Override
public final long getStateSize() throws Exception {
return 0;
FileSystem fs = FileSystem.get(backupUri, HadoopFileSystem.getHadoopConfiguration());
return fs.getContentSummary(new Path(backupUri)).getLength();
}
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册