attempt to call unbound fn

1.4k Views Asked by At

In my case, streamparse api were used to run locally and submit code to STORM cluster, when I ran it locally it was ok but when it is submitted to STORM cluster, I got

java.lang.RuntimeException: java.lang.IllegalStateException: Attempting to call unbound fn

clojure version is 1.5.1, storm version is 0.9.5, sparse 2.1.3

the error was due to calling "call-to-outside-function" within spout execute, and that function can be 3rd party library as well, the code is as follows:

(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])
            ))

Anyone has this issue before ?

0

There are 0 best solutions below