1.10版本 无法使用WATERMARK ，报空指针。
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 4/5
- Tiempo estimado
- 3-5 días
- Aptitud para principiantes
- 25/100
- Tipo de issue
- Error
- Claridad
- Bastante claro
- Estado de actividad
- Estancado
- Área
- stream-processing
Línea de trabajo
Comience con la sentencia CREATE TABLE del issue y el error CustomerWaterMarkerForLong del registro de Flink 1.10. Compare el campo bigint derivado de UNIX_TIMESTAMP y la sintaxis de WATERMARK con el comportamiento compatible de 1.10. Se considera terminado cuando el esquema informado contiene un ejemplo completo y funcional de WATERMARK y ya no produce el error de puntero nulo.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
日志样例
{"time":"2020-06-17 23:00:01.211","pushid":"pushback_send-BC110-12392212311","app":"mm"}
由于时间序列是bigint类型，用UNIX_TIMESTAMP进行转换
Flink运行日志报错：
ERROR com.dtstack.flink.sql.watermarker.CustomerWaterMarkerForLong -
java.lang.NullPointerException
建表语句：
CREATE TABLE MyTable (
time varchar ,
pushid varchar ,
app varchar ,
UNIX_TIMESTAMP(time, 'yyyy-MM-dd HH:mm:ss')*1000 bigint AS xctime ,
WATERMARK FOR xctime AS withOffset( xctime , 1000)
)
WITH (
type='kafka11',
bootstrapServers='kafka:9092',
offsetReset='latest',
topic='test_1',
groupId='flink_sql',
parallelism='4',
timezone='Asia/Shanghai',
topicIsPattern ='false',
sourcedatatype ='dt_nest'
);
CREATE TABLE MyResult(
app VARCHAR,
cnt BIGINT,
wStart timestamp
)WITH(
type ='elasticsearch6',
address ='eshost:9200',
cluster='bigdata-es5.6',
estype ='date',
index ='MyResult',
parallelism ='1',
id='0'
);
insert into MyResult
select
d.app ,
count(d.pushid) cnt ,
TUMBLE_START(d.ROWTIME, INTERVAL '3' SECOND) as wStart
from
MyTable as d
group by d.app,TUMBLE(d.ROWTIME, INTERVAL '3' SECOND);
可否提供一份完整的1.10版本 WATERMARK 语法案例。实际测试中无法使用
- 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
-
Dificultad 5/5 Más de una semana Aptitud para principiantes 20/100
DTStack/flinkStreamSQL#467 · 1 comentario ·
-
这个如何引入使用flink-connector-hive啊 Abierto
Dificultad 4/5 3-5 días Aptitud para principiantes 25/100
DTStack/flinkStreamSQL#437 · 3 comentarios ·
-
Dificultad 3/5 1-2 días Aptitud para principiantes 38/100
DTStack/flinkStreamSQL#432 · 1 comentario ·
-
新版FlinkStreamSQL已经融合进FlinkX项目 Abierto
Dificultad 5/5 Más de una semana Aptitud para principiantes 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 Abierto
Dificultad 5/5 Más de una semana Aptitud para principiantes 15/100
DTStack/flinkStreamSQL#430 · 1 comentario ·
Todos los issues de DTStack/flinkStreamSQL
Issues similares
-
bug untriaged
Dificultad 2/5 1-3 horas Aptitud para principiantes 84/100
opensearch-project/ml-commons#5094 ·
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 85/100
-
emitter:client:csharp feature
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
-
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
-
Two open-case totals on one screen: the Programs tile says 15,858 and the nav badge says 15,868 Abiertobug frontend maui-pilot
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100