Kafka Streams runner: merging windows and custom WindowFns
Los mantenedores suelen responder en 1 día
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 5/5
- Tiempo estimado
- Más de una semana
- Aptitud para principiantes
- 30/100
- Tipo de issue
- Nueva funcionalidad
- Claridad
- Necesita aclaración
- Estado de actividad
- Tranquilo
- Stack tecnológico
- java, kafka
- Área
- stream-processing
Línea de trabajo
Comienza con ReduceFnRunner, el respaldo de estado del Kafka Streams runner y el comportamiento de merging windows descrito en GroupByKeyTest$WindowTests.testGroupByKeyMergingWindows y CombineTest$WindowingTests.testSessionsCombine. Reproduce primero las pruebas de session windows sickbayed; se considera terminado cuando merging windows funcione y exista una ruta definida para WindowFns personalizados a través del SDK harness propietario.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
Two related windowing gaps in the Kafka Streams runner.
Merging windows. Session windows do not work. ReduceFnRunner drives merging through a merging window set that moves per-window state as windows merge, which the runner's state backing does not implement. GroupByKeyTest$WindowTests.testGroupByKeyMergingWindows and CombineTest$WindowingTests.testSessionsCombine are sickbayed for this.
Custom WindowFns. The runner rebuilds the standard WindowFns from their URNs and interprets them directly, which is what makes a pipeline from any SDK work. A WindowFn the user wrote is opaque to the runner and would have to be executed through the SDK harness that owns it.
Part of #18479.
- Lenguaje dominante
- Java
- Estrellas
- 8.7k
- Forks
- 4.7k
- Merge medio
- 2 d 7 h
- PR fusionados (30 d)
- 296
Preparar el entorno
- Sin Dockerfile ni archivo de Docker Compose
- Tiene una plantilla de pull request
- Leer la guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/beam
-
[Feature Request]: Support Protobuf 7.x in Python SDKPosiblemente ocupada @sofiathoren la tomó hace 6 días. AbiertoP2 python
Dificultad 2/5 1-3 horas Aptitud para principiantes 62/100
Los mantenedores suelen responder en 1 día
-
[Bug]: Row.toString throws for an ITERABLE field that is not backed by a ListPosiblemente ocupada @PDGGK la tomó hace 67 días. Abiertojava P3
Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
apache/beam#39624 · 2 reacciones ·
Los mantenedores suelen responder en 1 día
-
[Bug]: PubsubIO used in batch incorrect batch cutoff sizePosiblemente ocupada @1fanwang la tomó hace 55 días. Abiertobug io P3 pinned pubsub
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
apache/beam#28011 · 4 comentarios ·
Los mantenedores suelen responder en 1 día
-
build P3 sub-task
Dificultad 1/5 Menos de una hora Aptitud para principiantes 68/100
Los mantenedores suelen responder en 1 día
Todos los issues de apache/beam
Issues similares
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100
-
account bug communication lecture
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
Los mantenedores suelen responder en 1 día
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 66/100
Los mantenedores suelen responder en 1 día
-
area/server bug P2
Dificultad 2/5 1-3 horas Aptitud para principiantes 68/100
modelcontextprotocol/java-sdk#1196 ·
Los mantenedores suelen responder en 1 día