yzeng1618

> It seems like we could not restore a seatunnel job from a flink checkpoint/savepoint. I have tested this part before. If it is not a CDC synchronization task, you...

The upgrade mode referred to herein has not undergone testing, and its compatibility cannot be verified. It is recommended to attempt using the Zate engine.

> @yzeng1618 Will other fields in Kudu also have this issue, such as: BINARY Kudu BINARY is handled differently: - KuduTypeMapper maps Type.BINARY to SeaTunnel BYTES (PrimitiveByteArrayType), not to STRING....

> We need new flink 1.20.1 test container to verify it. https://github.com/apache/seatunnel/tree/dev/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink The code has now been simplified and the Flink20Container has been added.

> https://hub.docker.com/repository/docker/tyrantlucifer/flink/tags/1.20.2-scala_2.12_hadoop27/sha256-2a3f548cd690dd3718fbcd73208c9de7d28bbbd9385df3581ccf347128b390d0 > > I have pushed test docker image, tag is `tyrantlucifer/flink:1.20.2-scala_2.12_hadoop27` We've currently found that when using this Docker image, there seem to be some image-related issues during...

> We need new flink 1.20.1 test container to verify it. https://github.com/apache/seatunnel/tree/dev/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink The test container for Flink 1.20 has been added.

> We need new flink 1.20.1 test container to verify it. https://github.com/apache/seatunnel/tree/dev/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink It has been added.

> LGTM Because this commit is merged into dev, we need to resolve conflicts and then re-run the CI process. Please approve it again.

> waiting test case passes. > @yzeng1618 CI failed. Please check Currently, it seems that there is an issue with the CI (Continuous Integration) process of the dev (development) environment...

> Please merge dev. it fix the timeout issue. Have merged