This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a change to branch davidzollo-patch-1
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 4785ea4035 Update README.md
add 60f1007ab3 [Doc][MongoDB] Update CDC documentation for role and user
creation with clearer examples (#10423)
add f4ae3d97ea [Feature][Core][Checkpoint] Add checkpoint api (#10065)
add bee0e7d6a1 [Fix][Connector-V2][SelectDBCloud] Fix
NotSerializableException in engine sink action (#10412)
add cd60b80ddc [Doc] Fix the Deepwiki display in READE.md (#10438)
add 28b65d3fef [Feature][Connector-v2]Resolve null first column in CSV
Reader (#10383)
add 71bbaa15d5 Merge branch 'dev' into davidzollo-patch-1
No new revisions were added by this update.
Summary of changes:
docs/en/connectors/source/MongoDB-CDC.md | 61 ++---
docs/en/engines/zeta/rest-api-v2.md | 148 ++++++++++++
docs/zh/connectors/source/MongoDB-CDC.md | 61 ++---
docs/zh/engines/zeta/rest-api-v2.md | 142 ++++++++++++
.../file/source/reader/CsvReadStrategy.java | 114 ++++++----
.../file/source/reader/CsvReadStrategyTest.java | 55 +++++
.../test/resources/csv/utf8_bom_with_header.csv | 3 +
.../test/resources/csv/utf8_bom_without_header.csv | 2 +
.../file/local/SplitFileStrategyTest.java | 141 ++++++++++++
.../src/test/resources/utf8_bom_split.csv | 101 +++++++++
.../connectors/selectdb/config/SelectDBConfig.java | 7 +-
.../serialize/SelectDBConfigSerializableTest.java | 119 ++++++++++
seatunnel-core/seatunnel-starter/pom.xml | 6 +
.../starter/seatunnel/args/ClientCommandArgs.java | 25 ++
.../seatunnel/command/ClientExecuteCommand.java | 40 ++++
.../org/apache/seatunnel/engine/e2e/RestApiIT.java | 214 +++++++++++++++++
.../seatunnel/engine/client/job/JobClient.java | 31 +++
.../apache/seatunnel/engine/common/Constant.java | 2 +
.../engine/core/checkpoint/CheckpointCounts.java | 41 ++--
.../core/checkpoint/CheckpointHistoryEntry.java} | 12 +-
.../CheckpointInfo.java} | 26 +--
.../engine/core/checkpoint/CheckpointOverview.java | 24 +-
.../{Checkpoint.java => CheckpointStatus.java} | 18 +-
.../core/checkpoint/InProgressCheckpoint.java} | 17 +-
.../checkpoint/PipelineCheckpointOverview.java | 35 +--
...ava => SeaTunnelGetCheckpointHistoryCodec.java} | 85 ++++---
...va => SeaTunnelGetCheckpointOverviewCodec.java} | 24 +-
.../seatunnel/engine/server/JettyService.java | 11 +
.../seatunnel/engine/server/SeaTunnelServer.java | 3 +
.../server/checkpoint/CheckpointCoordinator.java | 51 ++++-
.../server/checkpoint/CheckpointManager.java | 17 +-
.../server/checkpoint/PendingCheckpoint.java | 10 +
.../engine/server/checkpoint/TaskStatistics.java | 9 +
.../monitor/CheckpointMonitorService.java | 252 +++++++++++++++++++++
.../seatunnel/engine/server/master/JobMaster.java | 3 +-
...ion.java => GetCheckpointHistoryOperation.java} | 60 +++--
...on.java => GetCheckpointOverviewOperation.java} | 33 +--
...rJarTask.java => GetCheckpointHistoryTask.java} | 30 ++-
...eteTask.java => GetCheckpointOverviewTask.java} | 19 +-
.../task/SeaTunnelMessageTaskFactoryProvider.java | 10 +
.../seatunnel/engine/server/rest/RestConstant.java | 2 +
.../rest/service/CheckpointMonitorRestService.java | 158 +++++++++++++
...oServlet.java => CheckpointHistoryServlet.java} | 34 +--
...Servlet.java => CheckpointOverviewServlet.java} | 21 +-
.../ClientToServerOperationDataSerializerHook.java | 8 +
.../checkpoint/CheckpointCoordinatorTest.java | 25 +-
.../server/checkpoint/CheckpointManagerTest.java | 3 +-
47 files changed, 1974 insertions(+), 339 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/resources/csv/utf8_bom_with_header.csv
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-base/src/test/resources/csv/utf8_bom_without_header.csv
create mode 100644
seatunnel-connectors-v2/connector-file/connector-file-local/src/test/resources/utf8_bom_split.csv
create mode 100644
seatunnel-connectors-v2/connector-selectdb-cloud/src/test/java/org/apache/seatunnel/connectors/selectdb/serialize/SelectDBConfigSerializableTest.java
copy
seatunnel-connectors-v2/connector-google-firestore/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/firestore/config/FirestoreParameters.java
=>
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/checkpoint/CheckpointCounts.java
(56%)
copy
seatunnel-engine/{seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PipelineLocation.java
=>
seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/checkpoint/CheckpointHistoryEntry.java}
(80%)
copy
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/{job/VertexInfo.java
=> checkpoint/CheckpointInfo.java} (69%)
copy
seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/commit/PaimonAggregatedCommitInfo.java
=>
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/checkpoint/CheckpointOverview.java
(62%)
copy
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/checkpoint/{Checkpoint.java
=> CheckpointStatus.java} (79%)
copy
seatunnel-engine/{seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/job/JobStatusData.java
=>
seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/checkpoint/InProgressCheckpoint.java}
(76%)
copy
seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/commit/PaimonAggregatedCommitInfo.java
=>
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/checkpoint/PipelineCheckpointOverview.java
(54%)
copy
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/{SeaTunnelSubmitJobCodec.java
=> SeaTunnelGetCheckpointHistoryCodec.java} (59%)
copy
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/{SeaTunnelGetJobInfoCodec.java
=> SeaTunnelGetCheckpointOverviewCodec.java} (87%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/monitor/CheckpointMonitorService.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/{GetJobInfoOperation.java
=> GetCheckpointHistoryOperation.java} (55%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/{GetJobInfoOperation.java
=> GetCheckpointOverviewOperation.java} (68%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/{UploadConnectorJarTask.java
=> GetCheckpointHistoryTask.java} (60%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/{WaitForJobCompleteTask.java
=> GetCheckpointOverviewTask.java} (74%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/service/CheckpointMonitorRestService.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/servlet/{JobInfoServlet.java
=> CheckpointHistoryServlet.java} (54%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/servlet/{JobInfoServlet.java
=> CheckpointOverviewServlet.java} (72%)
