当前位置:网站首页>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
边栏推荐
- SQL 开发的十个高级概念
- 测试3年,开口就要25k?面试完最多给15k...
- The classification of inter-process communication (IPC) and the development of communication methods
- postgresql ilike create function
- 超声图像三维拼接-可视化选择,总体思路
- 代码 Revert 后再次 Merge 会丢失的问题,已解决
- leetcode:358. K 距离间隔重排字符串
- CC0 与商业 IP:哪种模式更适合 NFT?
- ASEMI整流桥GBJ5010参数,GBJ5010电压,GBJ5010电流
- DOM-DOM树,一个DOM树有三种类型的节点
猜你喜欢
随机推荐
OpenCV founder: Open source must not be completely free!
postgresql ilike create function
Js prototype and prototype chain and prototype inheritance
聊聊对RPC的理解
【Unity入门计划】Unity2D动画(1)-动画系统的组成及功能的使用
Realization of vending machine function based on FPGA state machine
“京台高铁”亮相百度地图,真能在2035年建成吗?
CSAPP Data Lab
深度学习-第二次
JVM类加载机制
基于FPGA状态机的自动售货机功能实现
代码 Revert 后再次 Merge 会丢失的问题,已解决
入职数字ic设计后的一些工作心得
qtcreator调试webkit
言简意赅,说说 @Transactional 在项目中的使用
Detailed explanation of common methods of filtering matrix (array) elements in Matlab
IDE编译报错:Dangling metacharacter
【PHP】入门知识
The ifconfig compared with IP command
The classification of inter-process communication (IPC) and the development of communication methods