DTStack/flinkStreamSQL

官网数组类型字段解析示例不能运行

zhanghaoxuan-git opened this issue · 1 comments

CREATE TABLE ods (
id INT,
some_users ARRAY
) WITH (
...
);

CREATE TABLE dwd (
id INT,
user_no INT,
user_info VARCHAR
) WITH (
type ='console',
);

INSERT INTO dwd
SELECT id, user_info
FROM ods_foo
CROSS JOIN UNNEST(ods_foo.some_users) AS A (user_info);
报错不支持ARRAY类型!!

a49a commented

现已支持,请看Kafka Source文档