当前位置:网站首页>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 moretransient
边栏推荐
- 备战“金九银十”,软件测试功能 / 数据库 /linux/ 接口 / 自动化 / 测试开发面试真题解析
- Entity到Vo的转换
- alibaba数据同步组件canal的实践整理
- 报错处理:org.xml.sax.SAXParseException: 不允许有匹配 “[xX][mM][lL]“ 的处理指令目标
- mysql 死锁 Deadlock found when trying to get lock; try restarting transaction
- ①In-depth analysis of CAS SSO single sign-on framework source code
- ES进阶 函数功能语法新特性详解
- (Nips-2015)空间变换器网络
- 数据存储全方案----详解持久化技术
- 代码 Revert 后再次 Merge 会丢失的问题,已解决
猜你喜欢
随机推荐
Mysql_Note3
Oops Framework模板项目新手引导
AI+医疗:使用神经网络进行医学影像识别分析
HPSO and multi-core LSSVM based network intrusion detection
压力能变成动力
基于FPGA状态机的自动售货机功能实现
MySQL权限控制、分区表、快速复制表
经典面试题 之 GC垃圾收集器
夫妻一方婚内向异性大额转款,怎么判
YTU 2411: 谁去参加竞赛?【简单循环】
深度学习-第二次
ifconfig与ip命令的比较
MSP430如何给板子下载程序?(IAR MSPFET CCS)
shell脚本入门
MySQL的主从复制+读写分离+分库分表,看这一篇文章就够了
如何开展性能测试,你知道吗?
网络安全笔记第四天day4(kali基本操作)
八.数据的存储
qtcreator调试webkit
CSAPP Data Lab









