1

就我而言,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])
            ))

以前有人有这个问题吗?

4

0 回答 0