Flink SQL 使用滚动窗口，能不能获取到延迟数据，跟datastream一样，可以放到侧输出里面

Abierto

#467 abierto el 27/9/2024 1 comentario 0 reacciones 0 asignados Ver en GitHub

Nadie ha tomado este issue todavía.

Evaluación

Dificultad: 5/5
Tiempo estimado: Más de una semana
Aptitud para principiantes: 20/100

Tipo de issue: Nueva funcionalidad
Claridad: Necesita aclaración
Estado de actividad: Estancado
Stack tecnológico: java
Área: stream-processing

Línea de trabajo

No se mencionan archivos, pruebas ni puntos de entrada. Empieza por localizar la implementación de ventanas de tipo tumbling de Flink SQL y su gestión de los registros tardíos; después, compara el comportamiento disponible de side output con DataStream. Se considera terminado cuando los datos tardíos puedan dirigirse a un side output como se solicita.

Escrito por el modelo de indexación a partir del texto del issue.

Descripción

Este issue no tiene descripción.

Lenguaje dominante: Java
Estrellas: 2k
Forks: 913
Métricas de merge de PR: Sin PR fusionados en 30 d

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

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 DTStack/flinkStreamSQL

这个如何引入使用flink-connector-hive啊 Abierto

Dificultad 4/5 3-5 días Aptitud para principiantes 25/100

DTStack/flinkStreamSQL#437 · 3 comentarios · Abierto el 25/2/2022
kudu sink writemode参数没填写报NULLPointerException Abierto

Dificultad 3/5 1-2 días Aptitud para principiantes 38/100

DTStack/flinkStreamSQL#432 · 1 comentario · Abierto el 16/11/2021
新版FlinkStreamSQL已经融合进FlinkX项目 Abierto

Dificultad 5/5 Más de una semana Aptitud para principiantes 15/100

DTStack/flinkStreamSQL#431 · Abierto el 1/11/2021
有无对sql 语法校验的方法 Abierto

Dificultad 5/5 Más de una semana Aptitud para principiantes 15/100

DTStack/flinkStreamSQL#430 · 1 comentario · Abierto el 8/10/2021
flinkstreamsql kafka任务，开启checkpoint，如果我手动杀死任务，如何从指定的最后一次保存的checkpoint启动任务 Abierto

Dificultad 4/5 3-5 días Aptitud para principiantes 20/100

DTStack/flinkStreamSQL#428 · 3 comentarios · Abierto el 22/7/2021

Todos los issues de DTStack/flinkStreamSQL

Issues similares

[BUG] Unified agent on Bedrock Converse with no tools is unusable: an empty `toolConfig` is emitted and Bedrock rejects the request Abierto

bug untriaged

Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100

opensearch-project/ml-commons#5094 · Abierto el 22/9/2026
[Bug report] iceberg rest server load_table with refs fails precondition check "Cannot set metadata location with changes to table metadata: %s changes" for snapshots with statistics Abierto

bug

Dificultad 2/5 1-3 horas Aptitud para principiantes 85/100

apache/gravitino#13452 · Abierto el 22/9/2026
Support Test Project Creation for New Projects Abierto

emitter:client:csharp feature

Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100

microsoft/typespec#12027 · 1 comentario · 1 reacción · Abierto el 22/9/2026
Job worker stops polling silently when a poll throws an Error Abierto

affects/8.10 affects/8.9 component/clients kind/bug likelihood/mid severity/mid

Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100

camunda/camunda#63825 · Abierto el 22/9/2026
Two open-case totals on one screen: the Programs tile says 15,858 and the nav badge says 15,868 Abierto

bug frontend maui-pilot

Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100

Taleef7/workwell#651 · 1 comentario · Abierto el 22/9/2026

Más issues de Java