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