You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/24 06:12:00 UTC
[jira] [Closed] (FLINK-15175) syntax not supported in SQLClient
for TPCDS queries
[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kurt Young closed FLINK-15175.
------------------------------
Fix Version/s: 1.10.0
Resolution: Fixed
master: fc4927e41989be75866218c2a60aa914e1eedcd3
1.10.0: 3af8e1ef31aa61cf08ed910df32a1a26dd26f892
> syntax not supported in SQLClient for TPCDS queries
> ----------------------------------------------------
>
> Key: FLINK-15175
> URL: https://issues.apache.org/jira/browse/FLINK-15175
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client
> Affects Versions: 1.10.0
> Reporter: liupengcheng
> Assignee: liupengcheng
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> {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)