当前位置:网站首页>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
边栏推荐
- Realization of vending machine function based on FPGA state machine
- Detailed explanation of common methods of filtering matrix (array) elements in Matlab
- [4G/5G/6G专题基础-154]: 5G无线准入控制RAC(Radio Admission Control)
- OpenHarmony啃论文俱乐部-啃论文心得
- YTU 2418: C语言习题 矩阵元素变换
- Ninjutsu_v3_08_2020 - safety penetrating system installation
- 【PHP】入门知识
- 21天学习挑战赛第一周总结
- 如何解决高度塌陷
- Fatal error in launcher: Unable to create process using xxx --logdir logs(tensorboard使用)
猜你喜欢
随机推荐
2022茶艺师(中级)考试试题及模拟考试
postgresql ilike create function
【DB运营管理/开发解决方案】上海道宁为您提供提高工作便利性的集成开发工具——Orange
入职数字ic设计后的一些工作心得
数论基础-整除(编程例题)
0 in the figure, etc. LeetCode565. Array nesting
解决vim与外界的复制粘贴(不用安装插件)
小幻美图 API
117. 本地开发好的 SAP UI5 应用部署到 ABAP 服务器时,中文字符变成乱码的原因分析和解决方案
代码 Revert 后再次 Merge 会丢失的问题,已解决
否定语义转化层
微信公众号后台管理
聊聊对RPC的理解
压力能变成动力
维特智能惯导配置
comp3331-9331-22t1-midterm复习辅导-tutorial week 5
Ninjutsu_v3_08_2020-安全渗透系统安装
Oops novice template Framework project guide
超声三维重建总体架构
Geogebra 教程之 04 Geogebra 小程序








