当前位置:网站首页>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
边栏推荐
- Ninjutsu_v3_08_2020-安全渗透系统安装
- ifconfig与ip命令的比较
- Summary of Logstash log data write exception troubleshooting
- HPSO and multi-core LSSVM based network intrusion detection
- ROS源代码阅读(1)
- 年薪30W,BAT抢着要,懂面试技巧的测试人究竟多吃香?
- Salesforce解散中国团队,什么样的CRM产品更适合中国人
- OpenCV founder: Open source must not be completely free!
- 带你系统学习MySQL索引
- Matlab矩阵(数组)元素过滤常见方法详解
猜你喜欢

The practice of alibaba data synchronization component canal

Detailed explanation of common methods of filtering matrix (array) elements in Matlab

BUU刷题记录

How to solve the problem of Tomcat booting and crashing

alibaba数据同步组件canal的实践整理

MySQL - 一条SQL在MySQL中是如何被执行的?

Salesforce解散中国团队,什么样的CRM产品更适合中国人

正式发布丨VS Code 1.70

ARM开发(四)新手小白如何阅读芯片手册,裸机驱动开发步骤以及纯汇编实现点灯,汇编结合c点灯,c实现点灯

ESP32的环境配置(arduino arduino2.0 VScode platform哪个好用?)
随机推荐
【DB运营管理/开发解决方案】上海道宁为您提供提高工作便利性的集成开发工具——Orange
超声图像三维拼接-可视化选择,总体思路
四大组件---ContentResolver
今天聊聊接口幂等性校验
ES进阶 数组功能语法新特性详解
深度学习-第二次
【Pdf自动生成书签】
gRPC闭包调度器
Detailed explanation of common methods of filtering matrix (array) elements in Matlab
alibaba数据同步组件canal的实践整理
【idea 报错】 无效的目标发行版:17 的解决参考
HPSO and multi-core LSSVM based network intrusion detection
CC0 与商业 IP:哪种模式更适合 NFT?
经典面试题 之 GC垃圾收集器
OptiFDTD应用:用于光纤入波导耦合的硅纳米锥仿真
Logstash日志数据写入异常排查问题总结
SQL 开发的十个高级概念
TRCX: doping process analysis
思念家乡的月亮
维特智能惯导配置