CROSS JOIN UNNEST 血缘解析报错，可能要扩展 RelMdColumnOrigins.getColumnOrigins 方法实现，大佬有空支持下。

[sutao168]

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) ;

[jeff-zou]

使用dev分支，我pull request的代码有解决这个问题。

[sutao168]

好像没找到对应的解决代码，尝试更新最新代码运行还是不行。

在 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]

可以用这个的dev分支先：https://github.com/jeff-zou/flink-sql-lineage/tree/dev