如何给实时输入到风暴

我试图执行风暴，Actualy数据从某个端口emited，使用实施SerialPortEventListener 我收到错误如何给实时输入到风暴

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)

来源

2013-05-16 kannadhasan

您能分享您将拓扑提交给集群的代码片段吗？还有关于你的风暴版本的信息 – abhi

风暴壶嘴节目我听，（即）

看起来你没有在jar中捆绑所需的库。确保您的CLASSPATH设置正确，以包含所需的库，以便将它包含在jar中。

来源

2013-05-19 07:29:12

@G Gordon Worley III：我错过了一些jar来建立我现在正在从外部port.thanks数据表单收到您的答复.. – kannadhasan

如何给实时输入到风暴

回答

相关问题