错误

源代码如下:

tenv
                .sqlQuery("select" +
                        "hop_start(et, interval '1' hour,interval '3' hour) stt, " +
                        "hop_end(et, interval '1' hour,interval '3' hour) edt, " +
                        "itemId, " +
                        "count(*) ct " +
                        "from ub " +
                        "where behavior='pv' " +
                        "group by itemId, hop(et, interval '1' hour,interval '3' hour) ")
                .execute()
                .print();

报错:

SQL parse failed. Non-query expression encountered in illegal context

原因分析:

select 后漏掉了空格,导致与下一行的数据连到一起了.

这里多了个逗号,导致编译出错

解决

将select后添加一个空格即可

总结

总而言之,言而总之,用flink写sql是真tm的不方便.