开启增量checkpoint后Checkpointed Data Size还是很大

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

开启增量checkpoint后Checkpointed Data Size还是很大

pass


我使用的版本是1.13.1
 env.setStateBackend(new RocksDBStateBackend(checkpointDataUri, true));这样设置的
数据源量级是在百万级别。使用flinksql进行计算的。