开发者社区> 问答> 正文

RocksDBKeyedStateBackend如何写磁盘

请问RocksDBKeyedStateBackend是何时将state序列化到磁盘的, 窗口结束时间?还是配置的checkpoint周期,谢谢*来自志愿者整理的flink邮件归档

展开
收起
说了是一只鲳鱼 2021-12-07 11:11:28 778 0
1 条回答
写回答
取消 提交回答
  • 看到 RocksDBWriteBatchWrapper类有 flushIfNeeded()方法 , 是这个么?

    private void flushIfNeeded() throws RocksDBException {

    boolean needFlush = batch.count() == capacity || (batchSize > 0 &&

    getDataSize() >= batchSize);

    if (needFlush) {

    flush();

    }

    }

    batchSize 来自 state.backend.rocksdb.write-batch-size 参数的配置*来自志愿者整理的flink邮件归档

    2021-12-07 11:28:20
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载