flinkStreamSQL
flinkStreamSQL copied to clipboard
嵌套json 解析后输出的数据为null
嵌套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' );
sourcedatatype ='json' 问题,改为sourcedatatype ='dt_nest' dt_nest支持解析2级嵌套和数组