[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992490#comment-16992490 ]
Kurt Young commented on FLINK-15175: ------------------------------------ Hi [~liupengcheng], thanks for reporting this. We will look into this, and my gut feeling is there maybe some disconnection between SQL CLI and Flink SQL. > syntax not supported in SQLClient for TPCDS queries > ---------------------------------------------------- > > Key: FLINK-15175 > URL: https://issues.apache.org/jira/browse/FLINK-15175 > Project: Flink > Issue Type: Improvement > Components: Table SQL / Client > Affects Versions: 1.10.0 > Reporter: liupengcheng > Priority: Major > > {code:java} > Flink SQL> WITH customer_total_return AS > > ( SELECT > > sr_customer_sk AS ctr_customer_sk, > > sr_store_sk AS ctr_store_sk, > > sum(sr_return_amt) AS ctr_total_return > > FROM store_returns, date_dim > > WHERE sr_returned_date_sk = d_date_sk AND d_year = 2000 > > GROUP BY sr_customer_sk, sr_store_sk) > > SELECT c_customer_id > > FROM customer_total_return ctr1, store, customer > > WHERE ctr1.ctr_total_return > > > (SELECT avg(ctr_total_return) * 1.2 > > FROM customer_total_return ctr2 > > WHERE ctr1.ctr_store_sk = ctr2.ctr_store_sk) > > AND s_store_sk = ctr1.ctr_store_sk > > AND s_state = 'TN' > > AND ctr1.ctr_customer_sk = c_customer_sk > > ORDER BY c_customer_id > > LIMIT 100; > [ERROR] Unknown or invalid SQL statement. > {code} > It seems that the newest branch already support all TPCDS queries, but > currently the sql client parser has not supported yet. > Anyone already working on this? If not I can try it. -- This message was sent by Atlassian Jira (v8.3.4#803005)