[jira] [Created] (FLINK-20794) Support to select distinct columns in the Table API

[Shang Yuanchun (Jira)]

Dian Fu created FLINK-20794:
-------------------------------

             Summary: Support to select distinct columns in the Table API
                 Key: FLINK-20794
                 URL: https://issues.apache.org/jira/browse/FLINK-20794
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / API
            Reporter: Dian Fu
             Fix For: 1.13.0


Currently, there is no corresponding functionality in Table API for the following SQL:
{code:java}
SELECT DISTINCT users FROM Orders
{code}
For example, for the following job:
{code:java}
table.select("distinct a")
{code}
It will thrown the following exception:
{code:java}
org.apache.flink.table.api.ExpressionParserException: Could not parse expression at column 10: ',' expected but 'a' foundorg.apache.flink.table.api.ExpressionParserException: Could not parse expression at column 10: ',' expected but 'a' founddistinct a         ^
 at org.apache.flink.table.expressions.PlannerExpressionParserImpl$.throwError(PlannerExpressionParserImpl.scala:726) at org.apache.flink.table.expressions.PlannerExpressionParserImpl$.parseExpressionList(PlannerExpressionParserImpl.scala:710) at org.apache.flink.table.expressions.PlannerExpressionParserImpl.parseExpressionList(PlannerExpressionParserImpl.scala:47) at org.apache.flink.table.expressions.ExpressionParser.parseExpressionList(ExpressionParser.java:40) at org.apache.flink.table.api.internal.TableImpl.select(TableImpl.java:121){code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)