[Flink错误]SQL parse failed. Non-query expression encountered in illegal context

[Flink错误]SQL parse failed. Non-query expression encountered in illegal context,第1张

[Flink错误]SQL parse failed. Non-query expression encountered in illegal context 错误

源代码如下:

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的不方便.

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5573090.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-14
下一篇 2022-12-14

发表评论

登录后才能评论

评论列表(0条)

保存