[
https://issues.apache.org/jira/browse/APEXMALHAR-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongming Liang reassigned APEXMALHAR-2373:
------------------------------------------
Assignee: Dongming Liang
> JdbcOutputOperator does not handle NUMERIC type
> -----------------------------------------------
>
> Key: APEXMALHAR-2373
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2373
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Bhupesh Chawda
> Assignee: Dongming Liang
>
> Database: Oracle
> Column type NUMERIC gives following exception in JdbcPOJOInsertOutputOperator:
> 2016-12-19 18:42:26,032 DEBUG jdbc.JdbcPOJOInsertOutputOperator
> (JdbcPOJOInsertOutputOperator.java:populateColumnDataTypes(162)) - resultSet
> MetaData column count 3
> 2016-12-19 18:42:26,033 DEBUG jdbc.JdbcPOJOInsertOutputOperator
> (JdbcPOJOInsertOutputOperator.java:populateColumnDataTypes(170)) - column
> name ACCOUNT_NO type 2
> 2016-12-19 18:42:26,033 DEBUG jdbc.JdbcPOJOInsertOutputOperator
> (JdbcPOJOInsertOutputOperator.java:populateColumnDataTypes(170)) - column
> name NAME type 12
> 2016-12-19 18:42:26,033 DEBUG jdbc.JdbcPOJOInsertOutputOperator
> (JdbcPOJOInsertOutputOperator.java:populateColumnDataTypes(170)) - column
> name AMOUNT type 2
> 2016-12-19 18:42:26,033 DEBUG engine.StreamingContainer
> (StreamingContainer.java:setupNode(1333)) - activating 2 in container
> container_e15_1482167280022_0017_01_000002
> 2016-12-19 18:42:26,033 DEBUG jdbc.JdbcPOJOInsertOutputOperator
> (JdbcPOJOInsertOutputOperator.java:activate(134)) - insert statement is
> INSERT INTO test_output_event_table (ACCOUNT_NO,NAME,AMOUNT) VALUES (?,?,?)
> 2016-12-19 18:42:26,034 ERROR engine.StreamingContainer
> (StreamingContainer.java:run(1431)) - Abandoning deployment of operator
> OperatorDeployInfo[id=2,name=JdbcOutput,type=GENERIC,checkpoint={ffffffffffffffff,
> 0,
> 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=POJO's,sourceNodeId=1,sourcePortName=outputPort,locality=CONTAINER_LOCAL,partitionMask=0,partitionKeys=<null>]],outputs=[]]
> due to setup failure.
> java.lang.RuntimeException: unsupported data type 2
> at
> com.datatorrent.lib.db.jdbc.AbstractJdbcPOJOOutputOperator.handleUnknownDataType(AbstractJdbcPOJOOutputOperator.java:177)
> at
> com.datatorrent.lib.db.jdbc.AbstractJdbcPOJOOutputOperator.activate(AbstractJdbcPOJOOutputOperator.java:292)
> at
> com.datatorrent.lib.db.jdbc.JdbcPOJOInsertOutputOperator.activate(JdbcPOJOInsertOutputOperator.java:136)
> at
> com.datatorrent.lib.db.jdbc.JdbcPOJOInsertOutputOperator.activate(JdbcPOJOInsertOutputOperator.java:47)
> at com.datatorrent.stram.engine.Node.activate(Node.java:619)
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
