[
https://issues.apache.org/jira/browse/FLINK-9341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ken Geis closed FLINK-9341.
---------------------------
Resolution: Not A Bug
This issue happened because because I used BasicTypeInfo.DATE_TYPE_INFO in my
input format instead of SqlTimeTypeInfo.TIMESTAMP. I changed that and the error
went away.
I agree with [~Sergey Nuyanzin]'s suggestion to include the full class name in
the exception.
> Oracle: "Type is not supported: Date"
> -------------------------------------
>
> Key: FLINK-9341
> URL: https://issues.apache.org/jira/browse/FLINK-9341
> Project: Flink
> Issue Type: Bug
> Components: Table API & SQL
> Affects Versions: 1.4.2
> Reporter: Ken Geis
> Priority: Major
>
> When creating a Table from an Oracle JDBCInputFormat with a date column, I
> get the error "Type is not supported: Date". This happens with as simple a
> query as
> {code:java}
> SELECT SYSDATE FROM DUAL{code}
> Stack trace:
> {noformat}
> Caused by: org.apache.flink.table.api.TableException: Type is not supported:
> Date
> at
> org.apache.flink.table.api.TableException$.apply(exceptions.scala:53)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.calcite.FlinkTypeFactory$.org$apache$flink$table$calcite$FlinkTypeFactory$$typeInfoToSqlTypeName(FlinkTypeFactory.scala:336)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.calcite.FlinkTypeFactory.createTypeFromTypeInfo(FlinkTypeFactory.scala:68)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.calcite.FlinkTypeFactory$$anonfun$buildLogicalRowType$1.apply(FlinkTypeFactory.scala:198)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.calcite.FlinkTypeFactory$$anonfun$buildLogicalRowType$1.apply(FlinkTypeFactory.scala:195)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> ~[scala-library-2.11.11.jar:na]
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
> ~[scala-library-2.11.11.jar:na]
> at
> org.apache.flink.table.calcite.FlinkTypeFactory.buildLogicalRowType(FlinkTypeFactory.scala:195)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.plan.schema.InlineTable.getRowType(InlineTable.scala:105)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.api.TableEnvironment.scanInternal(TableEnvironment.scala:499)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.api.TableEnvironment.scan(TableEnvironment.scala:485)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.api.java.BatchTableEnvironment.fromDataSet(BatchTableEnvironment.scala:61)
> ~[flink-table_2.11-1.4.2.jar:1.4.2]
> at
> org.apache.flink.table.api.java.BatchTableEnvironment$fromDataSet$0.call(Unknown
> Source) ~[na:na]
> (at my code...)
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
