Hi 从报错看 CountDownLatch 这个方法无法 serializable，这个 class 没有实现 Serializable 接口。你可以按照这里的方法[1] 尝试解决下
[1] https://stackoverflow.com/questions/4551926/java-io-notserializableexception-while-writing-serializable-object-to-external-s/4552014 Best, Congxian 引领 <yrx73...@163.com> 于2020年8月24日周一 下午3:34写道： > > 使用场景：FLink 1.11.1 > 读取mysql，一直报序列化错误，但感觉需要序列化的bean对象已经序列化，实在百思不得其解，前来求教各位大佬！！！ 代码再附件！！！ > > Exception in thread "main" > org.apache.flink.api.common.InvalidProgramException: > java.util.concurrent.CountDownLatch@45ca843[Count = 2] 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:71) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.clean(StreamExecutionEnvironment.java:1901) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1614) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1571) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(StreamExecutionEnvironment.java:1553) > at com.hsq.APP.main(APP.java:43) > Caused by: java.io.NotSerializableException: > java.util.concurrent.CountDownLatch > 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) > ... 9 more > > 引领 > yrx73...@163.com > > <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=%E5%BC%95%E9%A2%86&uid=yrx73513%40163.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fqiyelogo%2FdefaultAvatar.png&items=%5B%22yrx73513%40163.com%22%5D> > 签名由 网易邮箱大师 <https://mail.163.com/dashi/dlpro.html?from=mail81> 定制 > >
