DTStack / DTStack/flinkStreamSQL

嵌套json 解析后输出的数据为null

Abierto
#332 1 comentario 0 reacciones 0 asignados Ver en GitHub
Lenguaje dominante
Java
Estrellas
2k
Forks
913
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

### 嵌套json 解析后输出的数据 uid字段一直为null
json日志格式
{
"time":"2020-06-15 19:16:29.243",
"topic":"room_chat",
"appname":"ms",
"info":{
"uid":427083
}
}

kafkasource 建表语句
CREATE TABLE kafka11source (
appname VARCHAR ,
topic VARCHAR ,
info.uid bigint as uid,
time VARCHAR
)
WITH (
type='kafka11',
bootstrapServers='hadoop04:9092',
offsetReset='latest',
topic='room_topic',
groupId='flink_sql,
parallelism='2',
timezone='Asia/Shanghai',
topicIsPattern ='false',
sourcedatatype ='json'
);

Guía de contribución

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

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.