当前位置:网站首页>flink The object probably contains or references non serializable fields.
flink The object probably contains or references non serializable fields.
2022-08-11 02:46:00 【胖胖胖胖胖虎】
Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: java.lang.ref.ReferenceQueue$Lock@11fc564b is not serializable. The object probably contains or references non serializable fields.
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:151)
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:126)
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:126)
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:126)
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:126)
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:126)
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:71)
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.clean(StreamExecutionEnvironment.java:1821)
at org.apache.flink.streaming.api.datastream.DataStream.clean(DataStream.java:188)
at org.apache.flink.streaming.api.datastream.KeyedStream.process(KeyedStream.java:398)
at org.apache.flink.streaming.api.datastream.KeyedStream.process(KeyedStream.java:374)
at com.xintujing.flinkdemo.text.UserCount_3.main(UserCount_3.java:53)
Caused by: java.io.NotSerializableException: java.lang.ref.ReferenceQueue$Lock
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
at org.apache.flink.util.InstantiationUtil.serializeObject(InstantiationUtil.java:586)
at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:133)
... 11 more
transient
边栏推荐
猜你喜欢
随机推荐
comp3331-9331-21t1-midterm复习
LitePal操作数据库
JS-DOM元素对象
shell [stdin/stdout/stderr][重定向]
【Unity入门计划】Unity2D动画(1)-动画系统的组成及功能的使用
花甲的思考
CSAPP Data Lab
TRCX: doping process analysis
MSP430如何给板子下载程序?(IAR MSPFET CCS)
sql 使用到where和groupby时建立索引结果为啥是这样,原理是什么?
Inter-process communication method (2) Named pipe
①In-depth analysis of CAS SSO single sign-on framework source code
redis学习五redis的持久化RDB,fork,copyonwrite,AOF,RDB&AOF混合使用
YTU 2411: 谁去参加竞赛?【简单循环】
IDE编译报错:Dangling metacharacter
网络安全笔记第四天day4(kali基本操作)
[oops-framework] Template project [oops-game-kit] Introduction
SIT221 Data Structures and Algorithms课程辅导
四大组件---ContentResolver
求和、计数的窗口函数应用









