Flink with Clojure Setup Run clj -M:aot to generate the java classes for the filter function Start a repl Load the flink.core namespace to execute the flink job