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/11 22:46:00 UTC
[jira] [Updated] (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 updated FLINK-9341:
----------------------------
Description:
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}
was:
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}
> 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)