Kafka Streams runner: splittable DoFn
I maintainer di solito rispondono entro 1 giorno
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 5/5
- Tempo stimato
- Più di una settimana
- Idoneità per principianti
- 35/100
- Tipo di issue
- Funzionalità
- Chiarezza
- Abbastanza chiara
- Stato di attività
- Tranquilla
- Stack tecnologico
- java, kafka
- Ambito
- stream-processing
Direzione di ricerca
Inizia con la traduzione, da parte del Kafka Streams runner, della primitiva Read deprecata e delle categorie della suite ValidatesRunner UsesBoundedSplittableParDo e UsesUnboundedSplittableParDo. Traccia come il runner gestisce le restrizioni, il checkpointing, i residui e lo splitting dinamico tramite la Fn API. Il lavoro è completo quando entrambe le categorie sono supportate invece di essere escluse, per DoFns splittable bounded e unbounded.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
The Kafka Streams runner does not support splittable DoFn, bounded or unbounded. Sources are read through the deprecated primitive Read, which the runner forces Read-based SDFs into during translation.
Supporting SDF means handling restrictions, checkpointing and residuals over the Fn API, along with dynamic splitting. The UsesBoundedSplittableParDo and UsesUnboundedSplittableParDo categories are excluded from the ValidatesRunner suite.
Part of #18479.
- Lingua principale
- Java
- Stelle
- 8.7k
- Fork
- 4.8k
- Merge medio
- 2g 12h
- PR unite (30g)
- 371
Preparare l'ambiente
- Nessun Dockerfile né file Docker Compose
- Ha un modello di pull request
- Leggi la guida per i contributori
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di apache/beam
-
Release notes links wrongApertaawaiting triage bug P3
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 67/100
apache/beam#41197 · 2 commenti ·
I maintainer di solito rispondono entro 1 giorno
-
[Bug]: [Python] WriteToJson silently rounds floats to 10 decimal placesForse già presa @Abhi2939 l’ha presa 2 giorni fa. Apertaio P2 python yaml
Difficoltà 2/5 1-3 ore Idoneità per principianti 62/100
apache/beam#41102 · 4 commenti ·
I maintainer di solito rispondono entro 1 giorno
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 68/100
apache/beam#39624 · 2 reazioni ·
I maintainer di solito rispondono entro 1 giorno
-
[Bug]: PubsubIO used in batch incorrect batch cutoff sizeForse già presa @1fanwang l’ha presa 79 giorni fa. Apertabug io P3 pinned pubsub
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100
apache/beam#28011 · 4 commenti ·
I maintainer di solito rispondono entro 1 giorno
-
build P3 sub-task
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 68/100
I maintainer di solito rispondono entro 1 giorno
Issue simili
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100
-
Type: Bug
Difficoltà 2/5 1-3 ore Idoneità per principianti 83/100
MovingBlocks/Terasology#5415 ·
-
type: possible bug
Difficoltà 2/5 1-3 ore Idoneità per principianti 66/100
-
面渣逆袭Spring事务传播机制勘误Aperta
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 80/100
itwanger/toBeBetterJavaer#218 ·
-
Markdown and Astro language servers do not start when the project path contains a non-ASCII character or a spaceForse già presa @RoiSoleil l’ha presa oggi. Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 78/100
eclipse-wildwebdeveloper/wildwebdeveloper#2277 ·
I maintainer di solito rispondono entro 1 giorno