【Flink】 is not serializable. The object probably contains or references non serializable fields

在idea本地执行Flink例子的时候出现如下图标红问题

Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: MysqlParam(url=jdbc:mysql://node01:3306/flink, username=root, password=root, sql=insert into first(name) values(?);) is not serializable. The object probably contains or references non serializable fields.
   at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:164)
   at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:132)
   at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:69)
   at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.clean(StreamExecutionEnvironment.java:2052)
   at org.apache.flink.streaming.api.datastream.DataStream.clean(DataStream.java:203)
   at org.apache.flink.streaming.api.datastream.DataStream.addSink(DataStream.java:1243)
   at com.flink.exampl

【Flink】 is not serializable. The object probably contains or references non serializable fields相关推荐

【Flink】TableException: A raw type backed by type information has no serializable
1.概述洗了一个flink程序如下 package com.flink.clickhouse.demo;import org.apache.flink.api.common.typeinfo.Typ ...
Flink SQL xxx is not serializable. The object probably contains or references non serializable field
Flink 版本:1.10.3 1. 现象在执行如下自定义 Socket Connector 示例: // 创建 Socket Source 表 String sourceSql = "C ...
【Flink】Flink状态的缩放（rescale）与键组（Key Group）设计
1.概述转载:Flink状态的缩放(rescale)与键组(Key Group)设计这个东东还没了解过.来看一下. 在之前那篇讲解Flink Timer的文章里,我曾经用三言两语简单解释了Key ...
【Flink】详解Flink的八种分区
简介 Flink是一个流处理框架,一个Flink-Job由多个Task/算子构成,逻辑层面构成一个链条,同时Flink支持并行操作,每一个并行度可以理解为一个数据管道称之为SubTask.我们画图来看 ...
【Flink】Flink 源码阅读笔记（20）- Flink 基于 Mailbox 的线程模型
1.概述转载:Flink 源码阅读笔记(20)- Flink 基于 Mailbox 的线程模型相似文章:[Flink]Flink 基于 MailBox 实现的 StreamTask 线程模型 Fl ...
【Flink】FLink 1.12 版本的 Row 类型中的 RowKind 是干嘛的
1.概述在[Flink]Flink 从 1.9.1 版本升级到 1.12.4 版本的注意事项以及过程升级的时候,偶然看到row类型多了一个属性. @PublicEvolving publi ...
【Flink】Flink 不支持部分 task 结束后进行 checkpoint
纪念一波,九师兄博客热门订阅专栏时常名列前茅,我飘了,哈哈哈哈,得意的笑 1.概述以前遇到一个问题,这个问题是这样的,一个FLink job,然后部分是离线任务,数据读取完毕了,就结束了.然后发现就 ...
【Flink】Flink 源码之Buffer Debloating
1.概述转载:[Flink]Flink 源码之Buffer Debloating 2.什么是Buffer debloating Buffer Debloating是Flink 1.14新增的优化方式 ...
【Flink】Metrics运作机制
1.概述转载并且补充:Flink源码剖析:Metrics运作机制 1. Metrics简介 1.1 什么是 Metrics? Flink 提供的 Metrics 可以在 Flink 内部收集一些指标 ...

【Flink】 is not serializable. The object probably contains or references non serializable fields

【Flink】 is not serializable. The object probably contains or references non serializable fields相关推荐

最新文章

热门文章