类的可序列化(不是pojo)

w8biq8rn  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(350)

在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  
    }   
}

相关问题