Bhupesh Chawda created APEXMALHAR-2373:
------------------------------------------
Summary: 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
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.4#6332)
