apache / apache/druid

Better tracking of SeekableStreamSupervisor status after reset

Offen
#8,317 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
Area - Streaming Ingestion Improvement
Vorherrschende Sprache
Java
Sterne
14.1k
Forks
3.8k
Ø Merge
1 T. 19 Std.
Gemergte PRs (30 T.)
209

Beschreibung

[The `SeekableStreamSupervisor` throws an exception after it successfully resets the offset for a partition](https://github.com/apache/incubator-druid/blob/master/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java#L2520-L2524). This looks strange to me because it's not really an exceptional case. I think it's throwing an exception to show to druid operators that the reset happened using the API introduced in #7428 which seems not very useful though. It would be probably better to show the time when the most recent reset happened.

Beitragsleitfaden

Beitragsleitfaden öffnen

Rechercherichtung

Beginnen Sie in indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java ungefähr bei den Zeilen 2520-2524, wo die Ausnahme auf eine erfolgreiche Zurücksetzung des Partitions-Offsets folgt. Überprüfen Sie die in #7428 eingeführte Reset-API und bestimmen Sie, wie der Zeitpunkt des neuesten Resets für Druid-Operatoren verfügbar gemacht werden sollte. Als abgeschlossen gilt dies, wenn der Reset-Status mit seinem neuesten Zeitpunkt nachverfolgt wird, statt als Ausnahmefall gemeldet zu werden.

Vom Indexierungsmodell aus dem Issue-Text verfasst.

Bewertung

Tech-Stack
java
Bereich
backend
Issue-Typ
Feature
Schwierigkeit
3/5
Geschätzter Aufwand
1-2 Tage
Aktivitätsstatus
Veraltet
Klarheit
Größtenteils klar
Anfängerfreundlichkeit
35/100

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.