If I remove the "TEMPORARY VIEW" and just inline the SQL, this works fine. This seems like a bug with temporary views.
On Wed, Nov 23, 2022 at 1:38 PM Dan Hill <quietgol...@gmail.com> wrote: > Looks related to this issue. > https://lists.apache.org/thread/1sb5bos6tjv39fh0wjkvmvht0824r4my > > In my case, it doesn't seem like it's a sink issue. Even if I change my > minicluster test to SELECT * it, it fails the same way. > > CREATE TEMPORARY VIEW `test_content_metrics_view` AS > SELECT > DATE_FORMAT(TUMBLE_ROWTIME(rowtime, INTERVAL '1' DAY), 'yyyy-MM-dd'), > ROW( > platform_id, > content_id > ) > FROM content_event > GROUP BY > platform_id, > content_id, > TUMBLE(rowtime, INTERVAL '1' DAY) > > SELECT * FROM test_content_metrics_view > > > > On Wed, Nov 23, 2022 at 1:19 PM Dan Hill <quietgol...@gmail.com> wrote: > >> I upgraded to Flink v1.16.0 and I get the same error. >> >> On Wed, Nov 23, 2022 at 9:47 AM Dan Hill <quietgol...@gmail.com> wrote: >> >>> For the error `Encountered "." at line 1, column 119.`, here are the >>> confusing parts: >>> >>> 1. The error happens when I executed the last part of the sql query: >>> >>> INSERT INTO `test_content_metrics` >>> SELECT * FROM `test_content_metrics_view` >>> >>> 2. Line 1 column 119 doesn't exist in that SQL statement. >>> 3. None of the SQL that I've written has a period "." in it. >>> >>> >>> >>> On Wed, Nov 23, 2022 at 8:32 AM Dan Hill <quietgol...@gmail.com> wrote: >>> >>>> I'm using Flink 1.14.4 >>>> >>>> On Wed, Nov 23, 2022, 02:28 yuxia <luoyu...@alumni.sjtu.edu.cn> wrote: >>>> >>>>> Hi, Dan. >>>>> I'm wondering what type of error you expect. IMO, I think most engines >>>>> throw parse error in such way which tell you encounter an unexpected >>>>> token. >>>>> >>>>> Best regards, >>>>> Yuxia >>>>> >>>>> ------------------------------ >>>>> *发件人: *"Dan Hill" <quietgol...@gmail.com> >>>>> *收件人: *"User" <user@flink.apache.org> >>>>> *发送时间: *星期三, 2022年 11 月 23日 下午 1:55:20 >>>>> *主题: *Weird Flink SQL error >>>>> >>>>> Hi. I'm hitting an obfuscated Flink SQL parser error. Is there a way >>>>> to get better errors for Flink SQL? I'm hitting it when I wrap some of >>>>> the >>>>> fields on an inner Row. >>>>> >>>>> >>>>> *Works* >>>>> >>>>> CREATE TEMPORARY VIEW `test_content_metrics_view` AS >>>>> SELECT >>>>> DATE_FORMAT(TUMBLE_ROWTIME(rowtime, INTERVAL '1' DAY), 'yyyy-MM-dd'), >>>>> platform_id, >>>>> content_id >>>>> FROM content_event >>>>> GROUP BY >>>>> platform_id, >>>>> content_id, >>>>> TUMBLE(rowtime, INTERVAL '1' DAY) >>>>> >>>>> CREATE TABLE test_content_metrics ( >>>>> dt STRING NOT NULL, >>>>> `platform_id` BIGINT, >>>>> `content_id` STRING >>>>> ) PARTITIONED BY (dt) WITH ( >>>>> 'connector' = 'filesystem', >>>>> 'path' = 'etl/test_content_metrics', >>>>> 'format' = 'json', >>>>> ) >>>>> >>>>> INSERT INTO `test_content_metrics` >>>>> SELECT * FROM `test_content_metrics_view` >>>>> >>>>> >>>>> *Fails* >>>>> >>>>> Wrapping a couple parameters in a Row causes the following exception. >>>>> >>>>> Caused by: org.apache.flink.sql.parser.impl.ParseException: >>>>> Encountered "." at line 1, column 119. >>>>> Was expecting one of: >>>>> ")" ... >>>>> "," ... >>>>> >>>>> >>>>> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.generateParseException(FlinkSqlParserImpl.java:40981) >>>>> >>>>> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.jj_consume_token(FlinkSqlParserImpl.java:40792) >>>>> >>>>> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.ParenthesizedSimpleIdentifierList(FlinkSqlParserImpl.java:25220) >>>>> >>>>> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.Expression3(FlinkSqlParserImpl.java:19925) >>>>> >>>>> org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.Expression2b(FlinkSqlParserImpl.java:19581) >>>>> [...] >>>>> >>>>> >>>>> CREATE TEMPORARY VIEW `test_content_metrics_view` AS >>>>> SELECT >>>>> DATE_FORMAT(TUMBLE_ROWTIME(rowtime, INTERVAL '1' DAY), 'yyyy-MM-dd'), >>>>> ROW( >>>>> platform_id, >>>>> content_id >>>>> ) >>>>> FROM content_event >>>>> GROUP BY >>>>> platform_id, >>>>> content_id, >>>>> TUMBLE(rowtime, INTERVAL '1' DAY) >>>>> >>>>> CREATE TABLE test_content_metrics ( >>>>> dt STRING NOT NULL, >>>>> `body` ROW( >>>>> `platform_id` BIGINT, >>>>> `content_id` STRING >>>>> ) >>>>> ) PARTITIONED BY (dt) WITH ( >>>>> 'connector' = 'filesystem', >>>>> 'path' = 'etl/test_content_metrics', >>>>> 'format' = 'json', >>>>> ) >>>>> >>>>> INSERT INTO `test_content_metrics` >>>>> SELECT * FROM `test_content_metrics_view` >>>>> >>>>> >>>>>
