You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by kcz <57...@qq.com.INVALID> on 2021/09/26 03:18:59 UTC

回复:flink-1.12.0(1.13.2也是这个问题) select datas[1].filed_1,datas[1].filed_2,除了第一个字段有值

soryy 大家,是我弄错了,逻辑是正确的,也可以取到值。




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "kcz"                                                                                    <573693104@qq.com&gt;;
发送时间:&nbsp;2021年9月26日(星期天) 上午10:53
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;flink-1.12.0(1.13.2也是这个问题) select datas[1].filed_1,datas[1].filed_2,除了第一个字段有值



除了第一个INDEX获取可以拿出值,往后的INDEX++ 无法获取到value,正确做法应该是什么的?我的array里面有很多字段,我都想要一个一个的查出来单独使用
CREATE TABLE KafkaTable (
&nbsp; datas array<row<filed_1 STRING,filed_2 INT&gt;&gt;
) WITH (
&nbsp; 'connector' = 'kafka',
&nbsp; 'topic' = 'user_behavior',
&nbsp; 'properties.bootstrap.servers' = 'localhost:9092',
&nbsp; 'properties.group.id' = 'testGroup',
&nbsp; 'scan.startup.mode' = 'earliest-offset',
&nbsp; 'format' = 'json'
);

SELECT datas ,datas [1].filed_1, datas [1].filed_2&nbsp; from KafkaTable;