You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
好像没找到对应的解决代码,尝试更新最新代码运行还是不行。
在 2024-04-27 16:14:18,jeff-zou ***@***.***> 写道:
使用dev分支,我pull request的代码有解决这个问题。
—
Reply to this email directly, view it on GitHub, or unsubscribe.
You are receiving this because you authored the thread.Message ID: ***@***.***>
jeff-zou
added a commit
to jeff-zou/flink-sql-lineage
that referenced
this issue
May 10, 2024
CREATE TABLE
kafka_source
(id
bigint,data
ARRAY<row<c1 bigint,c2 string>>) WITH (
'connector' = 'kafka',
'properties.bootstrap.servers' = 'hadoop101:9092',
'topic' = 't1',
'properties.group.id' = 'g1',
'scan.startup.mode' = 'earliest-offset',
'format' = 'json'
);
CREATE TABLE
sink_print
(id bigint,
c1 bigint,
c2 string
) WITH (
'connector' = 'print'
);
insert into sink_print
SELECT id, t.c1, t.c2
FROM kafka_source
CROSS JOIN UNNEST(data) AS t(c1,c2)
;
The text was updated successfully, but these errors were encountered: