flinkStreamSQL icon indicating copy to clipboard operation
flinkStreamSQL copied to clipboard

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

Open Yangxu1990 opened this issue 4 years ago • 1 comments

嵌套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' );

Yangxu1990 avatar Jun 15 '20 11:06 Yangxu1990

sourcedatatype ='json' 问题,改为sourcedatatype ='dt_nest' dt_nest支持解析2级嵌套和数组

Yangxu1990 avatar Jun 18 '20 01:06 Yangxu1990