`proxy` is not `Serializable` anymore in Clojure 1.9

Description

(defn my-rich
"不行的方法 会报
The implementation of the RichFlatMapFunction is not serializable."
[]
(proxy [RichFlatMapFunction] []
(flatMap [value out]
(log/info "使用了proxy" value)
(let [tomap (into {} value)
{:keys [shopid shopname billdate] :as data} (read-string (get tomap "body"))]
(.collect out (Tuple3. (str shopid billdate) (str data) 1))
))
))
clojure 1.8.0 is ok
but 1.9 1.10.beat5 will
The implementation of the RichFlatMapFunction is not serializable

Environment

win10
jdk 1.8

Activity

Show:
Alex Miller
November 27, 2018, 12:14 PM

This is intentional due to the security issues in

中小 行者
November 27, 2018, 10:34 AM

because flink spark .... need the future .

Declined
Your pinned fields
Click on the next to a field label to start pinning.

Assignee

Unassigned

Reporter

中小 行者

Priority

Major

Affects versions