maven - 数据洪流 : JDBC operator not working

Question

我正在替换 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)

Answer 1

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

这是一个例子
dt.operator."您的运算符(operator)名称".store.databaseDriver=jdbc.mysql
dt.operator."您的运算符(operator)名称".store.databaseUrl=....