apache / apache/druid

Better tracking of SeekableStreamSupervisor status after reset

Abierto
#8,317 0 comentarios 0 reacciones 0 asignados Ver en GitHub
Area - Streaming Ingestion Improvement
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

Abrir la 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

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.