comment donner entrée en temps réel à Storm

Je suis en train d'exécuter la tempête, les données actualy est emited de certains ports, en utilisant le programme de bec tempête Je suis à l'écoute, (par exemple) la mise en œuvre SerialPortEventListener Je reçois erreurcomment donner entrée en temps réel à Storm

no rxtxSerial in java.library.path thrown while loading gnu.io.RXTXCommDriver 
5399 [Thread-26] ERROR backtype.storm.util - Async loop died! 
java.lang.NoClassDefFoundError: Could not initialize class gnu.io.CommPortIdentifier 
    at movingAverage.LightEventSpout.open(LightEventSpout.java:53) 
    at backtype.storm.daemon.executor$fn__3985$fn__3997.invoke(executor.clj:460) 
    at backtype.storm.util$async_loop$fn__465.invoke(util.clj:375) 
    at clojure.lang.AFn.run(AFn.java:24) 
    at java.lang.Thread.run(Thread.java:722)

Source

2013-05-16 kannadhasan

pouvez-vous partager un extrait de code lorsque vous envoyez la topologie au cluster? Aussi des informations sur votre version de l'orage – abhi

Il semble que vous ayez échoué à regrouper la bibliothèque souhaitée dans le pot. Assurez-vous que votre CLASSPATH est correctement configuré pour inclure la bibliothèque souhaitée afin qu'elle soit incluse dans le pot.

Source

2013-05-19 07:29:12

@G Gordon Worley III: J'ai manqué un pot à construire maintenant je reçois des données de forme port.thanks externe pour votre réponse .. – kannadhasan

comment donner entrée en temps réel à Storm

Répondre

Questions connexes