You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "Bhupesh Chawda (JIRA)" <ji...@apache.org> on 2016/12/21 10:34:58 UTC
[jira] [Commented] (APEXMALHAR-2373) JdbcOutputOperator does not
handle NUMERIC type
[ https://issues.apache.org/jira/browse/APEXMALHAR-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15766713#comment-15766713 ]
Bhupesh Chawda commented on APEXMALHAR-2373:
--------------------------------------------
Same should also be handled in Jdbc Input Operators.
> 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)