This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 1fb21bafdc1 [fix](nereids) fix cast ipv4 to string (#51546)
add 1d50458feb3 [refactor](sync-job) remove sync load job (#51730)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/doris/common/Config.java | 37 --
fe/fe-core/pom.xml | 49 --
.../antlr4/org/apache/doris/nereids/DorisParser.g4 | 17 -
fe/fe-core/src/main/cup/sql_parser.cup | 83 ---
.../java/org/apache/doris/analysis/BinlogDesc.java | 67 ---
.../apache/doris/analysis/ChannelDescription.java | 115 +----
.../doris/analysis/CreateDataSyncJobStmt.java | 138 -----
.../apache/doris/analysis/PauseSyncJobStmt.java | 61 ---
.../apache/doris/analysis/ResumeSyncJobStmt.java | 61 ---
.../org/apache/doris/analysis/ShowSyncJobStmt.java | 102 ----
.../org/apache/doris/analysis/StopSyncJobStmt.java | 61 ---
.../main/java/org/apache/doris/catalog/Env.java | 26 -
.../apache/doris/load/sync/DataSyncJobType.java | 10 +-
.../org/apache/doris/load/sync/SyncChannel.java | 105 ----
.../doris/load/sync/SyncChannelCallback.java | 26 -
.../apache/doris/load/sync/SyncChannelHandle.java | 58 ---
.../org/apache/doris/load/sync/SyncChecker.java | 86 ----
.../apache/doris/load/sync/SyncDataConsumer.java | 50 --
.../apache/doris/load/sync/SyncDataReceiver.java | 36 --
.../org/apache/doris/load/sync/SyncFailMsg.java | 42 +-
.../java/org/apache/doris/load/sync/SyncJob.java | 379 +-------------
.../org/apache/doris/load/sync/SyncJobManager.java | 558 ---------------------
.../org/apache/doris/load/sync/SyncLifeCycle.java | 77 ---
.../org/apache/doris/load/sync/SyncTxnParam.java | 65 ---
.../apache/doris/load/sync/canal/CanalConfigs.java | 27 -
.../doris/load/sync/canal/CanalDestination.java | 82 +--
.../doris/load/sync/canal/CanalSyncChannel.java | 384 --------------
.../load/sync/canal/CanalSyncDataConsumer.java | 476 ------------------
.../load/sync/canal/CanalSyncDataReceiver.java | 118 -----
.../apache/doris/load/sync/canal/CanalSyncJob.java | 293 +----------
.../apache/doris/load/sync/canal/CanalUtils.java | 238 ---------
.../doris/load/sync/canal/SyncCanalClient.java | 115 -----
.../org/apache/doris/load/sync/model/Data.java | 52 --
.../org/apache/doris/load/sync/model/Events.java | 73 ---
.../doris/load/sync/position/EntryPosition.java | 177 -------
.../doris/load/sync/position/PositionMeta.java | 98 ----
.../doris/load/sync/position/PositionRange.java | 88 ----
.../doris/nereids/parser/LogicalPlanBuilder.java | 402 +++++----------
.../trees/plans/commands/ShowSyncJobCommand.java | 115 -----
.../commands/load/CreateDataSyncJobCommand.java | 182 -------
.../commands/load/PauseDataSyncJobCommand.java | 69 ---
.../commands/load/ResumeDataSyncJobCommand.java | 69 ---
.../commands/load/StopDataSyncJobCommand.java | 69 ---
.../trees/plans/commands/load/SyncJobName.java | 64 ---
.../trees/plans/visitor/CommandVisitor.java | 25 -
.../java/org/apache/doris/persist/EditLog.java | 13 -
.../org/apache/doris/persist/OperationType.java | 4 +-
.../doris/persist/meta/MetaPersistMethod.java | 6 -
.../doris/persist/meta/PersistMetaModules.java | 4 +-
.../main/java/org/apache/doris/qe/DdlExecutor.java | 22 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 23 -
.../apache/doris/task/SerialExecutorService.java | 80 ---
.../main/java/org/apache/doris/task/SyncTask.java | 71 ---
.../java/org/apache/doris/task/SyncTaskPool.java | 51 --
.../doris/analysis/CreateDataSyncJobStmtTest.java | 183 -------
.../apache/doris/load/sync/SyncJobManagerTest.java | 487 ------------------
.../org/apache/doris/load/sync/SyncJobTest.java | 96 ----
.../doris/load/sync/canal/CanalSyncDataTest.java | 468 -----------------
.../doris/load/sync/canal/CanalSyncJobTest.java | 425 ----------------
.../doris/load/sync/canal/CanalTestUtil.java | 94 ----
.../commands/CreateDataSyncJobCommandTest.java | 235 ---------
.../commands/PauseDataSyncJobCommandTest.java | 50 --
.../commands/ResumeDataSyncJobCommandTest.java | 50 --
.../plans/commands/StopDataSyncJobCommandTest.java | 51 --
.../doris/task/SerialExecutorServiceTest.java | 135 -----
.../suites/auth_call/test_ddl_restore_auth.groovy | 6 -
.../suites/load_p0/sync_job/test_sync_job.groovy | 21 -
.../show/test_show_sync_job_command.groovy | 61 ---
68 files changed, 148 insertions(+), 8013 deletions(-)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/BinlogDesc.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDataSyncJobStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/PauseSyncJobStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ResumeSyncJobStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSyncJobStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/analysis/StopSyncJobStmt.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncChannel.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncChannelCallback.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncChannelHandle.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncChecker.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncDataConsumer.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncDataReceiver.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncJobManager.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncLifeCycle.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/SyncTxnParam.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalConfigs.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalSyncChannel.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalSyncDataConsumer.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalSyncDataReceiver.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/CanalUtils.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/canal/SyncCanalClient.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/model/Data.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/model/Events.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/position/EntryPosition.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/position/PositionMeta.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/load/sync/position/PositionRange.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowSyncJobCommand.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/CreateDataSyncJobCommand.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/PauseDataSyncJobCommand.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/ResumeDataSyncJobCommand.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/StopDataSyncJobCommand.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/SyncJobName.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/task/SerialExecutorService.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/task/SyncTask.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/task/SyncTaskPool.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/analysis/CreateDataSyncJobStmtTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobManagerTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/sync/SyncJobTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/sync/canal/CanalSyncDataTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/sync/canal/CanalSyncJobTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/load/sync/canal/CanalTestUtil.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/CreateDataSyncJobCommandTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/PauseDataSyncJobCommandTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/ResumeDataSyncJobCommandTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/trees/plans/commands/StopDataSyncJobCommandTest.java
delete mode 100644
fe/fe-core/src/test/java/org/apache/doris/task/SerialExecutorServiceTest.java
delete mode 100644 regression-test/suites/load_p0/sync_job/test_sync_job.groovy
delete mode 100644
regression-test/suites/nereids_p0/show/test_show_sync_job_command.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
