最近笔者使用flink实现一些实时数据清洗(从kafka清洗数据写入到clickhouse)的功能,在编写flink作业后进行上传,发现运行的时候抛出:
java.io.NotSerializableException
,错误消息可能类似于 “org.apache.flink.streaming.api.functions.MapFunction implementation is not serializable”的错误。该错误引起了我的好奇:
方法引用与lambda底层原理&Java方法引用、lambda能被序列化么?
未经允许不得转载:小狮博客 » 方法引用与lambda底层原理&Java方法引用、lambda能被序列化么?