当前位置:网站首页>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
边栏推荐
猜你喜欢
年薪30W,BAT抢着要,懂面试技巧的测试人究竟多吃香?
ES6 advanced string processing new features
ARM开发(四)新手小白如何阅读芯片手册,裸机驱动开发步骤以及纯汇编实现点灯,汇编结合c点灯,c实现点灯
MSP430如何给板子下载程序?(IAR MSPFET CCS)
117. 本地开发好的 SAP UI5 应用部署到 ABAP 服务器时,中文字符变成乱码的原因分析和解决方案
入职数字ic设计后的一些工作心得
[Detailed explanation of C data storage] (1) - in-depth analysis of the storage of shaping data in memory
Matlab矩阵(数组)元素过滤常见方法详解
leetcode:358. K 距离间隔重排字符串
Detailed explanation of new features of ES advanced function syntax
随机推荐
花甲的思考
隐私计算融合应用研究
google搜索技巧——程序员推荐
《人生若如初见》命运多舛,人物饱满,朱亚文角色反差太惊喜
ifconfig与ip命令的比较
CSAPP Data Lab
What does the sanction of the mixer Tornado mean for the DeFi market?
Docker 链接sqlserver时出现en-us is an invalid culture错误解决方案
CC0 vs. commercial IP: which model is better for NFTs?
js原型和原型链及原型继承
正式发布丨VS Code 1.70
如何开展性能测试,你知道吗?
行业的思考
3342: String manipulation problem solving
【idea 报错】 无效的目标发行版:17 的解决参考
mysql 死锁 Deadlock found when trying to get lock; try restarting transaction
21天学习挑战赛第一周总结
Economic Misunderstandings in the Crypto World: Is Cash a Savings?Scarcity creates value?
2022年广东省安全员A证第三批(主要负责人)操作证考试题模拟考试平台操作
(CVPR-2017)在身体和潜在部位学习深度上下文感知特征以进行行人重识别