Flink - 类的可序列化（不是 POJO）

Question

在 apache flink 中不能序列化不是 POJO 的类吗？ 我有一个具有许多功能的实用程序类，我想向 Source 函数发送该实用程序类的对象，但 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  
    }   
}

Answer 1

使Utilities实现Serializable。