This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from ac4e880fb [Feature][Connector-V2][File] Optimize filesystem utils
(#3749)
add b1b46bfa1 [Feature][ST-Engine] Support engine restart job information
will not be lost (#3637)
No new revisions were added by this update.
Summary of changes:
.../engine/e2e/ClusterFaultToleranceIT.java | 149 +++++++++++++--------
.../engine/client/job/ClientJobProxy.java | 1 +
.../apache/seatunnel/engine/common/Constant.java | 16 ++-
seatunnel-engine/seatunnel-engine-server/pom.xml | 19 +--
.../seatunnel/engine/server/SeaTunnelServer.java | 2 +-
.../server/checkpoint/CheckpointManager.java | 4 +-
.../engine/server/dag/physical/SubPlan.java | 4 +-
.../engine/server/persistence/FileMapStore.java | 43 ++++--
.../server/persistence/FileMapStoreFactory.java | 22 ++-
.../serializable/TaskDataSerializerHook.java | 3 +
.../server/checkpoint/CheckpointManagerTest.java | 4 +-
.../engine/imap/storage/api/IMapStorage.java | 2 +-
.../storage/api/common/ProtoStuffSerializer.java | 11 ++
.../imap/storage/api/ProtoStuffSerializerTest.java | 91 +++++++++++++
.../engine/imap/storage/file/IMapFileStorage.java | 18 +--
.../imap/storage/file/IMapFileStorageTest.java | 45 +++++--
16 files changed, 312 insertions(+), 122 deletions(-)
copy
seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchCommitInfo.java
=>
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/persistence/FileMapStoreFactory.java
(66%)
create mode 100644
seatunnel-engine/seatunnel-engine-storage/imap-storage-api/src/test/java/org/apache/seatunnel/engine/imap/storage/api/ProtoStuffSerializerTest.java
