尝试调用未绑定的fn

6mw9ycah  于 2021-06-21  发布在  Storm
关注(0)|答案(0)|浏览(260)

在我的例子中,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])
            ))

以前有人有这个问题吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题