0

我正在替换 WordCountDemo 中的控制台运算符,但它在 STRAM 事件中给了我一个 operatorError。当我单击它时,它会显示空指针错误。我对数据流非常陌生。

这是完整的错误消息:

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

1 回答 1

0

我猜您没有设置 jdbc 运算符所需的属性。您需要设置驱动程序/databaseurl/用户名/密码

这是一个示例 dt.operator."your operator name".store.databaseDriver=jdbc.mysql dt.operator."your operator name".store.databaseUrl=....

于 2016-07-06T17:03:56.750 回答