[
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)
