当前位置:网站首页>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 【fat fat tiger】
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$Lockat 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
边栏推荐
- Summary of Logstash log data write exception troubleshooting
- Ninjutsu_v3_08_2020 - safety penetrating system installation
- OpenHarmony啃论文俱乐部-啃论文心得
- Mysq_Note4
- 【Unity入门计划】Unity2D动画(1)-动画系统的组成及功能的使用
- YTU 2411: 谁去参加竞赛?【简单循环】
- Research on the Application of Privacy Computing Fusion
- 八.数据的存储
- OpenCV founder: Open source must not be completely free!
- qtcreator调试webkit
猜你喜欢
随机推荐
面试常考的7种排序算法
深度学习中的模型设计
报错处理:org.xml.sax.SAXParseException: 不允许有匹配 “[xX][mM][lL]“ 的处理指令目标
Idea (优选)cherry-pick操作
[oops-framework] Template project [oops-game-kit] Introduction
SIT221 Data Structures and Algorithms课程辅导
MSP430如何给板子下载程序?(IAR MSPFET CCS)
0 in the figure, etc. LeetCode565. Array nesting
备战“金九银十”,软件测试功能 / 数据库 /linux/ 接口 / 自动化 / 测试开发面试真题解析
leetcode:358. K 距离间隔重排字符串
[4G/5G/6G专题基础-154]: 5G无线准入控制RAC(Radio Admission Control)
言简意赅,说说 @Transactional 在项目中的使用
HPSO and multi-core LSSVM based network intrusion detection
CC0 与商业 IP:哪种模式更适合 NFT?
OpenHarmony啃论文俱乐部-啃论文心得
How to solve the problem of Tomcat booting and crashing
最倒霉与最幸运
【Unity入门计划】Unity2D动画(1)-动画系统的组成及功能的使用
shell [stdin/stdout/stderr][重定向]
ifconfig与ip命令的比较