如何为storm提供实时输入

pu3pd22g  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(323)

我正在尝试执行storm,实际上数据是从某个端口发出的,使用我正在侦听的storm spout程序,(即)实现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)
kq4fsx7k

kq4fsx7k1#

看起来您未能在jar中绑定所需的库。确保您的 CLASSPATH 正确设置为包含所需的库,以便将其包含在jar中。

相关问题