Currently, syncJob transfer data upstream and downstream using Kryo serialization, performance is much worse than flink native serialization.
Therefore, it is necessary to produce a serialization implementation specifically for ChunJun based on flink serialization idea