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 "guaishushu1103@163.com" <gu...@163.com> on 2020/09/16 06:32:22 UTC

Flink SQL create view问题

当create_view和LATERAL TABLE 共用时 会出现字段找不到异常

语法：
CREATE TABLE billing_data_test (
message  STRING


create view v1 as
select T.*
from billing_data_test,
LATERAL TABLE(SplitUdtf(message)) as T(scate1,  scate2,  belong_local1,  ssrc2,  gift,  coupon,  local_type);

异常：
Caused by: org.apache.calcite.sql.validate.SqlValidatorException: Column 'message' not found in any table (com.dataplatform.flink.util.FlinkDebugThread)
[2020-09-16 14:32:04,857] INFO ---      at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) (com.dataplatform.flink.util.FlinkDebugThread)





guaishushu1103@163.com

Re: Flink SQL create view问题

Posted by godfrey he <go...@gmail.com>.

已知问题，已fix：https://issues.apache.org/jira/browse/FLINK-18750

guaishushu1103@163.com <gu...@163.com> 于2020年9月16日周三 下午2:32写道：

> 当create_view和LATERAL TABLE 共用时 会出现字段找不到异常
>
> 语法：
> CREATE TABLE billing_data_test (
> message  STRING
>
>
> create view v1 as
> select T.*
> from billing_data_test,
> LATERAL TABLE(SplitUdtf(message)) as T(scate1,  scate2,  belong_local1,
> ssrc2,  gift,  coupon,  local_type);
>
> 异常：
> Caused by: org.apache.calcite.sql.validate.SqlValidatorException: Column
> 'message' not found in any table
> (com.dataplatform.flink.util.FlinkDebugThread)
> [2020-09-16 14:32:04,857] INFO ---      at
> sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
> (com.dataplatform.flink.util.FlinkDebugThread)
>
>
>
>
>
> guaishushu1103@163.com
>