You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ken Geis (JIRA)" <ji...@apache.org> on 2018/05/15 17:17:00 UTC
[jira] [Closed] (FLINK-9341) Oracle: "Type is not supported: Date"
[ 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)