trinodb/trino

DFs received by coordinator are unacked

Open

#5429 aperta il 6 ott 2020

Vedi su GitHub
 (2 commenti) (0 reazioni) (0 assegnatari)Java (2678 fork)batch import
good first issue

Metriche repository

Star
 (9113 star)
Metriche merge PR
 (Merge medio 5g 9h) (306 PR mergiate in 30 g)

Descrizione

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

Guida contributor

Direzione di ricerca
Indaga la gestione della versione dei DF (frammenti di dati) tra coordinatore e worker. Comprendi come viene utilizzata la versione locale del coordinatore e perché i worker non ricevono conferme. Esamina la codebase per la gestione delle richieste/risposte DF e la logica di incremento della versione.
Tech stack
java
Dominio
backenddistributed systemsdatabase
Tipo issue
Bug
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
Mezza giornata
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Abbastanza chiara
Prerequisiti
JavaDistributed systems
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
45