Better tracking of SeekableStreamSupervisor status after reset
- 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
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