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/incubator-doris.git.
from df56588 [Temp Partition] Support add/drop/replace temp partitions
(#2828)
add ef4bb0c [RoutineLoad] Auto Resume RoutineLoadJob (#2958)
No new revisions were added by this update.
Summary of changes:
.../load-data/routine-load-manual.md | 56 +++++++-------
.../load-data/routine-load-manual_EN.md | 16 ++--
.../main/java/org/apache/doris/common/Config.java | 13 ++++
.../InternalErrorCode.java} | 35 +++++----
.../apache/doris/common/MetaNotFoundException.java | 4 +
.../org/apache/doris/common/UserException.java | 18 +++++
.../routineload/ErrorReason.java} | 34 ++++++---
.../load/routineload/KafkaRoutineLoadJob.java | 25 +++++--
.../doris/load/routineload/RoutineLoadJob.java | 61 +++++++++------
.../doris/load/routineload/RoutineLoadManager.java | 10 ++-
.../load/routineload/RoutineLoadScheduler.java | 5 +-
.../load/routineload/RoutineLoadTaskScheduler.java | 19 ++++-
.../doris/load/routineload/ScheduleRule.java | 86 ++++++++++++++++++++++
.../org/apache/doris/planner/OlapTableSink.java | 4 +-
.../load/routineload/KafkaRoutineLoadJobTest.java | 12 +--
.../doris/load/routineload/RoutineLoadJobTest.java | 7 +-
.../load/routineload/RoutineLoadManagerTest.java | 32 ++++++--
.../load/routineload/RoutineLoadSchedulerTest.java | 6 +-
.../org/apache/doris/rewrite/FEFunctionsTest.java | 24 +++---
.../transaction/GlobalTransactionMgrTest.java | 4 +-
20 files changed, 348 insertions(+), 123 deletions(-)
copy fe/src/main/java/org/apache/doris/{qe/AuditBuilder.java =>
common/InternalErrorCode.java} (60%)
copy fe/src/main/java/org/apache/doris/{qe/AuditBuilder.java =>
load/routineload/ErrorReason.java} (57%)
create mode 100644
fe/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
