[jira] [Created] (FLINK-5500) Error when created array literals

["Yuhong Hong (JIRA)" <ji...@apache.org>]

Yuhong Hong created FLINK-5500:
----------------------------------

             Summary: Error when created array literals 
                 Key: FLINK-5500
                 URL: https://issues.apache.org/jira/browse/FLINK-5500
             Project: Flink
          Issue Type: Bug
          Components: Table API & SQL
    Affects Versions: 1.2.0
            Reporter: Yuhong Hong


It will report error when i create an array literals on TableAPI or SQL.
TableAPI:
dataStream.toTable(tEnv).select("array(1,2,3)")
The complete stacktrace looks like:
{code:java}
Exception in thread "main" org.apache.flink.table.api.TableException: Result field does not match expected type. Expected: int[]; Actual: ObjectArrayTypeInfo<Integer>
	at org.apache.flink.table.typeutils.TypeConverter$.determineReturnType(TypeConverter.scala:109)
	at org.apache.flink.table.plan.nodes.datastream.DataStreamCalc.translateToPlan(DataStreamCalc.scala:79)
	at org.apache.flink.table.api.StreamTableEnvironment.translate(StreamTableEnvironment.scala:340)
	at org.apache.flink.table.api.StreamTableEnvironment.translate(StreamTableEnvironment.scala:322)
	at org.apache.flink.table.api.scala.StreamTableEnvironment.toDataStream(StreamTableEnvironment.scala:142)
	at org.apache.flink.table.api.scala.TableConversions.toDataStream(TableConversions.scala:52)
	at com.huawei.example.flink.SimpleSql$.main(SimpleSql.scala:77)
	at com.huawei.example.flink.SimpleSql.main(SimpleSql.scala)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
{code}

SQL:
tEnv.sql( "select ARRAY\[1,2,3\]  FROM  OrderA ")
{code:java}
Exception in thread "main" org.apache.flink.table.api.TableException: Type is not supported: ARRAY
	at org.apache.flink.table.api.TableException$.apply(exceptions.scala:51)
	at org.apache.flink.table.calcite.FlinkTypeFactory$.toTypeInfo(FlinkTypeFactory.scala:227)
	at org.apache.flink.table.plan.logical.LogicalRelNode$$anonfun$15.apply(operators.scala:516)
	at org.apache.flink.table.plan.logical.LogicalRelNode$$anonfun$15.apply(operators.scala:515)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
	at scala.collection.Iterator$class.foreach(Iterator.scala:727)
	at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
	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:244)
	at scala.collection.AbstractTraversable.map(Traversable.scala:105)
	at org.apache.flink.table.plan.logical.LogicalRelNode.<init>(operators.scala:515)
	at org.apache.flink.table.api.StreamTableEnvironment.sql(StreamTableEnvironment.scala:183)
	at com.huawei.example.flink.SimpleSql$.main(SimpleSql.scala:62)
{code}

The calcite parse the sql and will translate the array to type ArraySqlType, but the toTypeInfo in FlinkTypeFactory just support ArrayRelType.




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)