当前位置:网站首页>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
边栏推荐
- ①CAS SSO单点登录框架源码深度分析
- Pytorch/TensorFlow/Numpy常用函数汇总
- MySQL - 一条SQL在MySQL中是如何被执行的?
- Gaussian beam focused by thermal lens
- js中的this问题
- 维特智能惯导配置
- ifconfig与ip命令的比较
- Inter-process communication method (2) Named pipe
- ASEMI整流桥GBJ5010参数,GBJ5010电压,GBJ5010电流
- ①In-depth analysis of CAS SSO single sign-on framework source code
猜你喜欢

Vulnhub靶机:GEMINI INC_ 2

【Unity入门计划】Unity2D动画(1)-动画系统的组成及功能的使用

ES6 advanced string processing new features

redis学习五redis的持久化RDB,fork,copyonwrite,AOF,RDB&AOF混合使用

Tomca启动闪退问题如何解决

TRCX:掺杂过程分析

Docker 链接sqlserver时出现en-us is an invalid culture错误解决方案

BUU刷题记录

ES6进阶 字符串处理新特性

Summary of Logstash log data write exception troubleshooting
随机推荐
IDE编译报错:Dangling metacharacter
OptiFDTD应用:用于光纤入波导耦合的硅纳米锥仿真
全局大喇叭--广播机制
Mask RCNN 网络详解
Entity到Vo的转换
3342:字符串操作 题解
Idea (优选)cherry-pick操作
MSP430如何给板子下载程序?(IAR MSPFET CCS)
Economic Misunderstandings in the Crypto World: Is Cash a Savings?Scarcity creates value?
CSAPP Data Lab
Multi-threaded ThreadPoolExecutor
SQL 开发的十个高级概念
YTU 2418: C语言习题 矩阵元素变换
超声三维重建总体架构
Entity to Vo conversion
shell [stdin/stdout/stderr][重定向]
alibaba数据同步组件canal的实践整理
八.数据的存储
js中的this问题
【idea 报错】 无效的目标发行版:17 的解决参考