[
https://issues.apache.org/jira/browse/FLINK-18401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-18401.
---------------------------
Fix Version/s: (was: 1.11.0)
Resolution: Not A Bug
I think this is not a bug. If you want to test general Sort in streaming sql,
you have to enable {{table.exec.non-temporal-sort.enabled=true}} which is false
by default.
> A streaming sql has "Sort on a non-time-attribute field is not supported"
> -------------------------------------------------------------------------
>
> Key: FLINK-18401
> URL: https://issues.apache.org/jira/browse/FLINK-18401
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.11.0
> Environment: I run the sql using sql -gateway.
> *The sql is:*
> CREATE TABLE `int8_tbl` (
> q1 bigint, q2 bigint
> ) WITH (
> 'connector'='filesystem',
> 'csv.field-delimiter'='|',
>
> 'path'='/defender_test_data/daily_regression_test_stream_postgres_1.10/tests.postgres.cases.test_join/sources/int8_tbl.csv',
> 'csv.null-literal'='',
> 'format'='csv'
> )
> select * from int8_tbl i1 left join (select * from int8_tbl i2 join (select
> 123 as x) ss on i2.q1 = x) as i3 on i1.q2 = i3.q2
> order by 1, 2;
> *The input data is:*
> 123|456
> 123|4567890123456789
> 4567890123456789|123
> 4567890123456789|4567890123456789
> 4567890123456789|-4567890123456789
> Reporter: xiaojin.wy
> Priority: Major
>
> Caused by: org.apache.flink.table.api.TableException: Sort on a
> non-time-attribute field is not supported.
> at
> org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSort.translateToPlanInternal(StreamExecSort.scala:106)
> at
> org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSort.translateToPlanInternal(StreamExecSort.scala:59)
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:58)
> at
> org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecSort.translateToPlan(StreamExecSort.scala:59)
> at
> org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToTransformation(StreamExecLegacySink.scala:158)
> at
> org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlanInternal(StreamExecLegacySink.scala:82)
> at
> org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlanInternal(StreamExecLegacySink.scala:48)
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:58)
> at
> org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlan(StreamExecLegacySink.scala:48)
> at
> org.apache.flink.table.planner.delegation.StreamPlanner$$anonfun$translateToPlan$1.apply(StreamPlanner.scala:67)
> at
> org.apache.flink.table.planner.delegation.StreamPlanner$$anonfun$translateToPlan$1.apply(StreamPlanner.scala:66)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at scala.collection.Iterator$class.foreach(Iterator.scala:891)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
> at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> at
> org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:66)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:166)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1249)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translateAndClearBuffer(TableEnvironmentImpl.java:1241)
> at
> org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.getPipeline(StreamTableEnvironmentImpl.java:317)
> at
> com.ververica.flink.table.gateway.context.ExecutionContext.createPipeline(ExecutionContext.java:223)
> at
> com.ververica.flink.table.gateway.operation.SelectOperation.lambda$null$0(SelectOperation.java:225)
> at
> com.ververica.flink.table.gateway.deployment.DeploymentUtil.wrapHadoopUserNameIfNeeded(DeploymentUtil.java:48)
> at
> com.ververica.flink.table.gateway.operation.SelectOperation.lambda$executeQueryInternal$1(SelectOperation.java:220)
> at
> com.ververica.flink.table.gateway.context.ExecutionContext.wrapClassLoaderWithException(ExecutionContext.java:197)
> at
> com.ververica.flink.table.gateway.operation.SelectOperation.executeQueryInternal(SelectOperation.java:219)
> ... 48 more
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
