前言

笔者脑仁本来就不大,但是就是喜欢遇到一堆让人头疼的故事。气着气着发现,嗯,脑仁又小了。这里笔者主要记录着笔者在进行FlinkSQL过程中所遇到的一些大的或者小的问题。

Q1: SQL的解析失败

1
org.apache.flink.table.api.SqlParserException: SQL parse failed. Non-query expression encountered in illegal context

故事背景:笔者从Phoenix拿到数据后,在FLink中将表初始化并注册一下,然后再根据用户提供的SQL来进行查询,那么问题来了,为啥就出现了解析失败,找不到呢?

这个问题,怪笔者粗心大意。笔者在进行表注册的时候,把注册表写死了,也就意味着,用户查询的表和笔者的表不一致,能找到就见鬼了。果然笔者脑仁太小了。