在我的例子中,streamparseapi被用来在本地运行并将代码提交给storm集群,当我在本地运行它时,它是可以的,但是当它提交给storm集群时,我得到了
java.lang.runtimeexception:java.lang.illegalstateexception:尝试调用未绑定的fn
clojure版本为1.5.1,storm版本为0.9.5,稀疏版本为2.1.3
该错误是由于在spoutexecute内调用“call to outside function”,该函数也可以是第三方库,代码如下:
(defn call-to-outside-function [someArg](do stuff ....))
(defspout kw-spout ["something"]
[conf context collector]
(spout
(nextTuple []
(call-to-outside-function "someArgs")
(emit-spout! collector ("not important"))
)
(ack [id])
))
以前有人有这个问题吗?
暂无答案!
目前还没有任何答案,快来回答吧!