就我而言,streamparse api用于在本地运行并将代码提交到STORM集群,当我在本地运行它时没问题,但是当它提交到STORM集群时,我得到了
java.lang.RuntimeException: java.lang.IllegalStateException: 试图调用未绑定的 fn
clojure 版本是 1.5.1,storm 版本是 0.9.5,sparse 2.1.3
该错误是由于在 spout 执行中调用“call-to-outside-function”引起的,该函数也可以是 3rd 方库,代码如下:
(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])
))
以前有人有这个问题吗?