flink1.11 sql使用问题

[魏烽]

各位大佬好：

在使用flink1.11 sql客户端的时候，只能只用最基本的count，group by、order by、join等都无法实现，请问这个是什么原因呢，感谢！


Flink SQL> select count(t2.superid) from cdp_profile_union t1 inner join cdp_crowd_10002 t2 on t1.superid=t2.superid;

[ERROR] Could not execute SQL statement. Reason:

org.apache.flink.table.api.ValidationException: SQL validation failed. null


Flink SQL> select superid from cdp_profile_union group by superid;

[ERROR] Could not execute SQL statement. Reason:

org.apache.flink.table.api.ValidationException: SQL validation failed. null

[Shengkai Fang]

能展示下完整的例子吗？ 我用的时候没有这种情况。

魏烽 <[hidden email]>于2020年8月11日 周二下午10:27写道：

> 各位大佬好：
>
> 在使用flink1.11 sql客户端的时候，只能只用最基本的count，group by、order
> by、join等都无法实现，请问这个是什么原因呢，感谢！
>
>
> Flink SQL> select count(t2.superid) from cdp_profile_union t1 inner join
> cdp_crowd_10002 t2 on t1.superid=t2.superid;
>
> [ERROR] Could not execute SQL statement. Reason:
>
> org.apache.flink.table.api.ValidationException: SQL validation failed. null
>
>
> Flink SQL> select superid from cdp_profile_union group by superid;
>
> [ERROR] Could not execute SQL statement. Reason:
>
> org.apache.flink.table.api.ValidationException: SQL validation failed. null
>

[魏烽]

您好：

    我使用的场景是连接postgreps catalog，直接对postgrep的表进行操作，但是只能有最简单的count操作，其它sql操作都无法实现，感谢！

 原始邮件
发件人: Shengkai Fang<[hidden email]>
收件人: user-zh<[hidden email]>
发送时间: 2020年8月11日(周二) 22:54
主题: Re: flink1.11 sql使用问题


能展示下完整的例子吗？ 我用的时候没有这种情况。

魏烽 <[hidden email]<mailto:[hidden email]>>于2020年8月11日 周二下午10:27写道：

> 各位大佬好：
>
> 在使用flink1.11 sql客户端的时候，只能只用最基本的count，group by、order
> by、join等都无法实现，请问这个是什么原因呢，感谢！
>
>
> Flink SQL> select count(t2.superid) from cdp_profile_union t1 inner join
> cdp_crowd_10002 t2 on t1.superid=t2.superid;
>
> [ERROR] Could not execute SQL statement. Reason:
>
> org.apache.flink.table.api.ValidationException: SQL validation failed. null
>
>
> Flink SQL> select superid from cdp_profile_union group by superid;
>
> [ERROR] Could not execute SQL statement. Reason:
>
> org.apache.flink.table.api.ValidationException: SQL validation failed. null
>