Better tracking of SeekableStreamSupervisor status after reset
- Lenguaje dominante
- Java
- Estrellas
- 14.1k
- Forks
- 3.8k
- Merge medio
- 1 d 19 h
- PR fusionados (30 d)
- 209
Descripción
[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.
Guía de contribución
Línea de trabajo
Comience en indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java alrededor de las líneas 2520-2524, donde la excepción se produce después de un restablecimiento correcto del offset de la partición. Revise la API de reset introducida en #7428 y determine cómo debe exponerse a los operadores de Druid la hora del reset más reciente. Se considera terminado cuando el estado del reset se registra con su hora más reciente, en lugar de informarse como un caso excepcional.
Escrito por el modelo de indexación a partir del texto del issue.
Evaluación
- Stack tecnológico
- java
- Área
- backend
- Tipo de issue
- Nueva funcionalidad
- Dificultad
- 3/5
- Tiempo estimado
- 1-2 días
- Estado de actividad
- Estancado
- Claridad
- Bastante claro
- Aptitud para principiantes
- 35/100