[FLINK-15175] syntax not supported in SQLClient for TPCDS queries

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.0
• Component/s: Table SQL / Client
• Labels: pull-request-available
• Assignee: liupengcheng
• Reporter: liupengcheng
• Created: 10/Dec/19 10:24
• Updated: 24/Dec/19 06:11
• Resolved: 24/Dec/19 06:11

Description

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.

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.

Issue Links

• links to: GitHub Pull Request #10619