trinodb/trino

DFs received by coordinator are unacked

Open

#5,429 创建于 2020年10月6日

在 GitHub 查看
 (2 评论) (0 反应) (0 负责人)Java (2,678 fork)batch import
good first issue

仓库指标

Star
 (9,113 star)
PR 合并指标
 (平均合并 5天 9小时) (30 天内合并 306 个 PR)

描述

Currently, coordinator fetches DF delta between local version and worker version. Coordinator sends it's local version as part of DF request. Worker is free to remove stored DFs based on coordinator local version. However, coordinator does not acknowledge received DFs until next DF is available. Therefore workers can keep DFs locally longer then needed.

This can be resolved by worker artificially bumping DFs version until there are still unacknowledged DFs

贡献者指南