[问题踩坑]Flink1.11.1SQLView中UDTF调用异常Column‘xxx‘notfoundinanytable

篇首语：本文由编程笔记#小编为大家整理，主要介绍了[问题踩坑]Flink 1.11.1 SQL View中UDTF调用异常 Column ‘xxx‘ not found in any table相关的知识，希望对你有一定的参考价值。

在Flink 1.11.1版本中&＃xff0c;执行下面的Flink SQL&＃xff0c;会抛出异常&＃xff1a;
"org.apache.calcite.sql.validate.SqlValidatorException: Column &＃39;message&＃39; not found in any table"


-- 创建Kafka数据源表test_table
CREATE TABLE test_table
(
username STRING,
message STRING
) WITH (
&＃39;connector&＃39; &＃61; &＃39;kafka&＃39;,
&＃39;topic&＃39; &＃61; &＃39;test_topic&＃39;,
&＃39;properties.bootstrap.servers&＃39; &＃61; &＃39;127.0.0.1:9092&＃39;,
&＃39;properties.group.id&＃39; &＃61; &＃39;test_group&＃39;,
&＃39;format&＃39; &＃61; &＃39;json&＃39;,
&＃39;scan.startup.mode&＃39; &＃61; &＃39;earliest-offset&＃39;
);
-- 注册自定义表值函数(UDTF) testUdtf
CREATE FUNCTION testUdtf AS &＃39;com.test.shadow.TestUdtf&＃39;
-- SQL视图test_view中包含UDTF调用testUdtf(message)
CREATE VIEW test_view AS
SELECT username,meaasge,ip,url FROM test_table,
LATERAL TABLE(testUdtf(message)) as T(ip,url);


这是Flink 1.11.1的一个Bug&＃xff0c;原因是在视图View的扩展查询里&＃xff0c;关键词"LATERAL"丢失了。导致当使用Flink SQL创建的视图里&＃xff0c;包含UDTF调用时&＃xff0c;会出现参数字段找不到的异常。
目前Flink 1.11.2已修复该Bug&＃xff0c;可通过升级Flink版本来解决该问题。

社区类似问题&＃xff1a;flink sql多层view嵌套&＃xff0c;字段not found
官方Bug链接&＃xff1a;SqlValidatorException thrown when select from a view which contains a UDTF call