[ 
https://issues.apache.org/jira/browse/FLINK-11819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Lifei Chen updated FLINK-11819:
-------------------------------
    Description: 
I am using flink v1.7.1, when I use flink sql to order by an attribute (not 
time attribute), the error logs is as follow.

 

sql:

```

"SELECT * FROM events order by tenantId"

```

```

Exception in thread "main" org.apache.flink.table.api.TableException: Cannot 
generate a valid execution plan for the given query:

FlinkLogicalSort(sort0=[$2], dir0=[ASC])
 FlinkLogicalNativeTableScan(table=[[_DataStreamTable_0]])

This exception indicates that the query uses an unsupported SQL feature.
 Please check the documentation for the set of currently supported SQL features.
 at 
org.apache.flink.table.api.TableEnvironment.runVolcanoPlanner(TableEnvironment.scala:377)
 at 
org.apache.flink.table.api.TableEnvironment.optimizePhysicalPlan(TableEnvironment.scala:302)
 at 
org.apache.flink.table.api.StreamTableEnvironment.optimize(StreamTableEnvironment.scala:814)
 at 
org.apache.flink.table.api.StreamTableEnvironment.translate(StreamTableEnvironment.scala:860)
 at 
org.apache.flink.table.api.java.StreamTableEnvironment.toRetractStream(StreamTableEnvironment.scala:305)
 at 
org.apache.flink.table.api.java.StreamTableEnvironment.toRetractStream(StreamTableEnvironment.scala:248)

```

 

So as for no, only time attribute is supported by flink for command `order by`, 
additional attribute is not supported yet, Is that right ?

If so, there is a mistake, indicated that other attribute except for `time 
attribute` is supported .

related links: 
[https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/sql.html#orderby--limit]

  was:
I am using flink v1.7.1, when I use flink sql to order by an attribute (not 
time attribute), the error logs is as follow.

```

Exception in thread "main" org.apache.flink.table.api.TableException: Cannot 
generate a valid execution plan for the given query:

FlinkLogicalSort(sort0=[$2], dir0=[ASC])
 FlinkLogicalNativeTableScan(table=[[_DataStreamTable_0]])

This exception indicates that the query uses an unsupported SQL feature.
Please check the documentation for the set of currently supported SQL features.
 at 
org.apache.flink.table.api.TableEnvironment.runVolcanoPlanner(TableEnvironment.scala:377)
 at 
org.apache.flink.table.api.TableEnvironment.optimizePhysicalPlan(TableEnvironment.scala:302)
 at 
org.apache.flink.table.api.StreamTableEnvironment.optimize(StreamTableEnvironment.scala:814)
 at 
org.apache.flink.table.api.StreamTableEnvironment.translate(StreamTableEnvironment.scala:860)
 at 
org.apache.flink.table.api.java.StreamTableEnvironment.toRetractStream(StreamTableEnvironment.scala:305)
 at 
org.apache.flink.table.api.java.StreamTableEnvironment.toRetractStream(StreamTableEnvironment.scala:248)

```

 

So as for no, only time attribute is supported by flink for command `order by`, 
additional attribute is not supported yet, Is that right ?

If so, there is a mistake, indicated that other attribute except for `time 
attribute` is supported .

related links: 
https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/sql.html#orderby--limit


> Additional attribute for order by not support by flink sql, but told 
> supported in doc
> -------------------------------------------------------------------------------------
>
>                 Key: FLINK-11819
>                 URL: https://issues.apache.org/jira/browse/FLINK-11819
>             Project: Flink
>          Issue Type: Bug
>          Components: Documentation
>    Affects Versions: 1.7.2
>            Reporter: Lifei Chen
>            Assignee: Lifei Chen
>            Priority: Major
>             Fix For: 1.7.3
>
>   Original Estimate: 3h
>  Remaining Estimate: 3h
>
> I am using flink v1.7.1, when I use flink sql to order by an attribute (not 
> time attribute), the error logs is as follow.
>  
> sql:
> ```
> "SELECT * FROM events order by tenantId"
> ```
> ```
> Exception in thread "main" org.apache.flink.table.api.TableException: Cannot 
> generate a valid execution plan for the given query:
> FlinkLogicalSort(sort0=[$2], dir0=[ASC])
>  FlinkLogicalNativeTableScan(table=[[_DataStreamTable_0]])
> This exception indicates that the query uses an unsupported SQL feature.
>  Please check the documentation for the set of currently supported SQL 
> features.
>  at 
> org.apache.flink.table.api.TableEnvironment.runVolcanoPlanner(TableEnvironment.scala:377)
>  at 
> org.apache.flink.table.api.TableEnvironment.optimizePhysicalPlan(TableEnvironment.scala:302)
>  at 
> org.apache.flink.table.api.StreamTableEnvironment.optimize(StreamTableEnvironment.scala:814)
>  at 
> org.apache.flink.table.api.StreamTableEnvironment.translate(StreamTableEnvironment.scala:860)
>  at 
> org.apache.flink.table.api.java.StreamTableEnvironment.toRetractStream(StreamTableEnvironment.scala:305)
>  at 
> org.apache.flink.table.api.java.StreamTableEnvironment.toRetractStream(StreamTableEnvironment.scala:248)
> ```
>  
> So as for no, only time attribute is supported by flink for command `order 
> by`, additional attribute is not supported yet, Is that right ?
> If so, there is a mistake, indicated that other attribute except for `time 
> attribute` is supported .
> related links: 
> [https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/sql.html#orderby--limit]



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to