各位大佬好:

在使用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

回复