嵌套json 解析后输出的数据为null
Nessuno ha ancora preso questa issue.
Valutazione
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Idoneità per principianti
- 35/100
- Tipo di issue
- Bug
- Chiarezza
- Da chiarire
- Stato di attività
- Ferma
- Ambito
- data-engineering, stream-processing
Direzione di ricerca
Riproduci il report utilizzando la DDL della sorgente Kafka fornita, il JSON annidato e la configurazione sourcedatatype='json'. Inizia tracciando la gestione della sorgente JSON Kafka per la proiezione annidata info.uid; il lavoro è concluso quando la uid proiettata contiene 427083 invece di null.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Descrizione
嵌套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'
);
- Lingua principale
- Java
- Stelle
- 2k
- Fork
- 913
- Metriche di merge delle PR
- Nessuna PR unita negli ultimi 30g
Guida per i contributori
Nessuna guida per i contributori indicizzata per questo repository
Come iniziare
- Leggi tutta la issue e poi la guida ai contributi del progetto.
- Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
- Fai un fork del repository e lavora su un branch.
- Apri una pull request che faccia riferimento al numero della issue.
Altre issue di DTStack/flinkStreamSQL
-
Difficoltà 5/5 Più di una settimana Idoneità per principianti 20/100
DTStack/flinkStreamSQL#467 · 1 commento ·
-
Difficoltà 4/5 3-5 giorni Idoneità per principianti 25/100
DTStack/flinkStreamSQL#437 · 3 commenti ·
-
Difficoltà 3/5 1-2 giorni Idoneità per principianti 38/100
DTStack/flinkStreamSQL#432 · 1 commento ·
-
Difficoltà 5/5 Più di una settimana Idoneità per principianti 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 Aperta
Difficoltà 5/5 Più di una settimana Idoneità per principianti 15/100
DTStack/flinkStreamSQL#430 · 1 commento ·
Tutte le issue di DTStack/flinkStreamSQL
Issue simili
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 75/100
elastic/gradle-plugins#157 ·
-
enhancement Tools
Difficoltà 1/5 Meno di un'ora Idoneità per principianti 75/100
-
Difficoltà 2/5 1-3 ore Idoneità per principianti 70/100
apache/rocketmq-dashboard#5008 ·
-
bug
Difficoltà 2/5 1-3 ore Idoneità per principianti 75/100
-
DETECT_PARAMETER_NAMES=false silently disables @ConstructorProperties-based Creator detection too Aperta
Difficoltà 2/5 1-3 ore Idoneità per principianti 70/100
FasterXML/jackson-databind#6229 ·