2016-06-17 82 views
0

我正在替换WordCountDemo中的控制台操作员,但它在STRAM Events中给我一个operatorError。当我点击它时,它会显示我出现空指针错误。 datatorrent我很新。DataTorrent:JDBC操作员不工作

下面是完整的错误消息:

Abandoning deployment due to setup failure. java.lang.NullPointerException 
    at java.lang.Class.forName0(Native Method) 
    at java.lang.Class.forName(Class.java:195) 
    at com.datatorrent.lib.db.jdbc.JdbcStore.connect(JdbcStore.java:163) 
    at com.datatorrent.lib.db.jdbc.JdbcTransactionalStore.connect(JdbcTransactionalStore.java:118) 
    at com.datatorrent.lib.db.AbstractTransactionableStoreOutputOperator.setup(AbstractTransactionableStoreOutputOperator.java:94) 
    at com.datatorrent.lib.db.jdbc.AbstractJdbcTransactionableOutputOperator.setup(AbstractJdbcTransactionableOutputOperator.java:81) 
    at com.datatorrent.lib.db.jdbc.AbstractJdbcTransactionableOutputOperator.setup(AbstractJdbcTransactionableOutputOperator.java:58) 
    at com.datatorrent.stram.engine.Node.setup(Node.java:182) 
    at com.datatorrent.stram.engine.StreamingContainer.setupNode(StreamingContainer.java:1290) 
    at com.datatorrent.stram.engine.StreamingContainer.access$100(StreamingContainer.java:129) 
    at com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1369) 

回答

0

我猜你没有设置由JDBC运营商所需要的性能。您需要设置驱动器/ databaseurl /用户名/密码

下面是一个例子 dt.operator。 “你的运营商名称” .store.databaseDriver = jdbc.mysql dt.operator。 “你的运营商名称” .store。 databaseUrl = ....