apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bhupesh Chawda (JIRA)" <j...@apache.org>
Subject [jira] [Created] (APEXMALHAR-2373) JdbcOutputOperator does not handle NUMERIC type
Date Wed, 21 Dec 2016 10:33:58 GMT
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)

Mime
View raw message