apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Thomas Weise (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (APEXMALHAR-2382) User should not be required to create "dt_meta" table while using JdbcPOJOInsertOutputOperator
Date Tue, 10 Jan 2017 10:07:58 GMT

    [ https://issues.apache.org/jira/browse/APEXMALHAR-2382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814556#comment-15814556
] 

Thomas Weise commented on APEXMALHAR-2382:
------------------------------------------

IMO tables should never be created automatically, at least not by default. Schema modifications
in well administered systems require special privileges. If you really want such an auto create
option for demo or related purposes, then it should be a property that the user needs explicitly.

Also please fix the table name...

> User should not be required to create "dt_meta" table while using JdbcPOJOInsertOutputOperator
> ----------------------------------------------------------------------------------------------
>
>                 Key: APEXMALHAR-2382
>                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2382
>             Project: Apache Apex Malhar
>          Issue Type: Bug
>            Reporter: Hitesh Kapoor
>            Assignee: Hitesh Kapoor
>
> f the "dt_meta" does not exist in the database, error is thrown as:
> {code}
> 2016-10-28 06:33:22,327 ERROR com.datatorrent.stram.engine.StreamingContainer: Abandoning
deployment of operator OperatorDeployInfo[id=3,name=JdbcOutput,type=GENERIC,checkpoint={ffffffffffffffff,
0, 0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=input,streamId=From Table to Table,sourceNodeId=1,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[]]
due to setup failure.
> java.lang.RuntimeException: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException:
Table 'tmp.dt_meta' doesn't exist
> 	at com.datatorrent.lib.db.jdbc.JdbcTransactionalStore.getCommittedWindowIdHelper(JdbcTransactionalStore.java:240)
> 	at com.datatorrent.lib.db.jdbc.JdbcTransactionalStore.getCommittedWindowId(JdbcTransactionalStore.java:196)
> 	at com.datatorrent.lib.db.AbstractTransactionableStoreOutputOperator.setup(AbstractTransactionableStoreOutputOperator.java:97)
> 	at com.datatorrent.lib.db.jdbc.AbstractJdbcTransactionableOutputOperator.setup(AbstractJdbcTransactionableOutputOperator.java:95)
> 	at com.datatorrent.lib.db.jdbc.JdbcPOJOInsertOutputOperator.setup(JdbcPOJOInsertOutputOperator.java:60)
> 	at com.datatorrent.lib.db.jdbc.JdbcPOJOInsertOutputOperator.setup(JdbcPOJOInsertOutputOperator.java:48)
> 	at com.datatorrent.stram.engine.Node.setup(Node.java:188)
> 	at com.datatorrent.stram.engine.StreamingContainer.setupNode(StreamingContainer.java:1317)
> 	at com.datatorrent.stram.engine.StreamingContainer.access$100(StreamingContainer.java:129)
> 	at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1396)
> Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Table 'tmp.dt_meta'
doesn't exist
> 	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
> 	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
> 	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> 	at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
> 	at com.mysql.jdbc.Util.handleNewInstance(Util.java:403)
> 	at com.mysql.jdbc.Util.getInstance(Util.java:378)
> 	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1031)
> 	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:957)
> 	at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3361)
> 	at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3295)
> 	at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:1852)
> 	at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:1975)
> 	at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2476)
> 	at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:1404)
> 	at com.mysql.jdbc.PreparedStatement.executeQuery(PreparedStatement.java:1546)
> 	at com.datatorrent.lib.db.jdbc.JdbcTransactionalStore.getCommittedWindowIdHelper(JdbcTransactionalStore.java:229)
> 	... 9 more
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message