回复： flink1.11 sql问题

Tue, 25 Aug 2020 03:32:06 -0700 

CREATE TABLE test (
    a VARCHAR, 
    b INT
 ) WITH (
    'connector'='kafka', 
    'topic'='test', 
    'properties.bootstrap.servers'='xxx',
    'properties.group.id'='groupid',
    'scan.startup.mode'='group-offsets', 
    'format'='json'
);
我说的是在source阶段，读过来的数据，如果某个key的值是嵌套json或者json数组，那么，format=json是获取不到这个字段值的，直接显示为空


在2020年08月25日 16:23，zilong xiao<[email protected]> 写道：
直接CAST不可以吗？

酷酷的浑蛋 <[email protected]> 于2020年8月25日周二 下午3:46写道：

关键是那个值不是固定的，有时候是json，有时候是json数组，没办法固定写一个，现在我只想把value当做字符串获取到，难道没有办法吗




在2020年08月25日 15:34，taochanglian<[email protected]> 写道：
flinksql，处理json ，对象的话用row，数组的话用array获取具体的值。

在 2020/8/25 14:59, 酷酷的浑蛋 写道:
还是这个问题，如果字段的值有时候是json有时候是json数组，那么我只想把它当做字符串显示，该怎么写？




在2020年08月25日 14:05，酷酷的浑蛋<[email protected]> 写道：
我知道了




在2020年08月25日 13:58，酷酷的浑蛋<[email protected]> 写道：




flink1.11
读取json数据时format=“json”，当数据中某个字段的值是[{"a1":{"a2":"v2"}}]类似这种嵌套，flink取到的值就是空，这个怎么处理？

回复