Flink SQL create view问题

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink SQL create view问题

guaishushu1103@163.com
当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)





[hidden email]
Reply | Threaded
Open this post in threaded view
|

Re: Flink SQL create view问题

godfrey he
已知问题,已fix:https://issues.apache.org/jira/browse/FLINK-18750

[hidden email] <[hidden email]> 于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)
>
>
>
>
>
> [hidden email]
>