在apache flink中不能序列化不是pojo的类吗?我有一个实用程序类,它有许多函数,我想向源函数发送一个该实用程序类的对象,但是flink抛出了序列化异常。
主要类别:
Utilities utilities = new Utilities();
DataStream<MyData> dataStream = env.addSource(new MySource(configData,utilities))
实用程序类:
public class Utilities {
public Utilities() {
//default constructor
}
public String fun1() {
//Do something
}
public String fun2() {
//Do something
}
}
1条答案
按热度按时间kmpatx3s1#
制造
Utilities
实施Serializable
.