wosyingjun / leek Goto Github PK

HI， 看到Flume里面的配置只是stock.log，没看到其他说明。能不能介绍下数据来源，以及如何在一个新环境中搭建配置起来？

18:21:53.021 [EventManagerImp] ERROR c.a.j.d.supervisor.SyncProcessEvent - Failed Sync Process
java.lang.RuntimeException: java.lang.IllegalStateException: Attempting to call unbound fn: #'carbonite.api/register-serializers
at backtype.storm.serialization.SerializationFactory.getKryo(SerializationFactory.java:75) ~[classes/:na]
at backtype.storm.serialization.KryoValuesDeserializer.(KryoValuesDeserializer.java:33) ~[classes/:na]
at backtype.storm.serialization.KryoTupleDeserializer.(KryoTupleDeserializer.java:52) ~[classes/:na]
at com.alibaba.jstorm.daemon.worker.WorkerData.updateKryoSerializer(WorkerData.java:420) ~[classes/:na]
at com.alibaba.jstorm.daemon.worker.WorkerData.(WorkerData.java:376) ~[classes/:na]
at com.alibaba.jstorm.daemon.worker.Worker.(Worker.java:67) ~[classes/:na]
at com.alibaba.jstorm.daemon.worker.Worker.mk_worker(Worker.java:248) ~[classes/:na]
at com.alibaba.jstorm.daemon.supervisor.SyncProcessEvent.launchWorker(SyncProcessEvent.java:440) ~[classes/:na]
at com.alibaba.jstorm.daemon.supervisor.SyncProcessEvent.startNewWorkers(SyncProcessEvent.java:987) ~[classes/:na]
at com.alibaba.jstorm.daemon.supervisor.SyncProcessEvent.run(SyncProcessEvent.java:182) ~[classes/:na]
at com.alibaba.jstorm.daemon.supervisor.SyncSupervisorEvent.run(SyncSupervisorEvent.java:191) ~[classes/:na]
at com.alibaba.jstorm.event.EventManagerImp.run(EventManagerImp.java:71) ~[classes/:na]
at com.alibaba.jstorm.callback.AsyncLoopRunnable.run(AsyncLoopRunnable.java:95) ~[classes/:na]
at java.lang.Thread.run(Thread.java:724) ~[na:1.7.0_25]
Caused by: java.lang.IllegalStateException: Attempting to call unbound fn: #'carbonite.api/register-serializers
at clojure.lang.Var$Unbound.throwArity(Var.java:43) ~[clojure-1.6.0.jar:na]
at clojure.lang.AFn.invoke(AFn.java:36) ~[clojure-1.6.0.jar:na]
at clojure.lang.Var.invoke(Var.java:383) ~[clojure-1.6.0.jar:na]
at carbonite.JavaBridge.registerPrimitives(JavaBridge.java:43) ~[carbonite-1.4.0.jar:na]
at backtype.storm.serialization.SerializationFactory.getKryo(SerializationFactory.java:72) ~[classes/:na]
... 13 common frames omitted
本地运行jstorm2.1.1 任务均报这个错
目前怀疑是这两个jar版本不兼容 ，有碰到过类似的问题请指点下啊