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

Question

是否无法在 apache flink 中序列化不是 POJO 的 classes？ 我有一个实用程序 class，它有很多功能，我想向 Source 函数发送该实用程序 class 的对象，但 flink 抛出序列化异常。

主要Class:

Utilities utilities = new Utilities();
DataStream<MyData> dataStream = env.addSource(new MySource(configData,utilities))

实用工具class：

public class Utilities {


    public Utilities() {
        //default constructor
    }


    public String fun1() {

        //Do something  
    }   

    public String fun2() {

        //Do something  
    }   
}

Answer 1

使 Utilities 实施 Serializable。