Flink - сериализуемый класс (не POJO)

Question

Разве невозможно сериализовать классы, которые не являются POJO в apache flink?У меня есть служебный класс, который имеет много функций, и я хочу отправить функции Source объект этого служебного класса, но flink вызывает исключение сериализации.

Main Class:

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.