2016-06-17 10 views
0

Ich ersetze den Konsolenoperator in WordCountDemo, aber es gibt mir einen Operatorfehler in STRAM-Ereignisse. Wenn ich darauf klicke, zeigt es mir nullpointer Fehler. Ich bin neu bei Datatorrent.DataTorrent: JDBC-Operator funktioniert nicht

Dies ist die komplette Fehlermeldung:

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) 

Antwort

0

Ich denke, Sie nicht die Eigenschaften haben festgelegt, die von jdbc Operator benötigt wird. Sie benötigen Fahrer/databaseurl/Benutzername/Passwort

Hier ist ein Beispiel dt.operator zu setzen. "Ihr Name des Bedieners" .store.databaseDriver = jdbc.mysql dt.operator. "Ihr Name des Bedieners" .Lagerung. databaseUrl = ....

Verwandte Themen