This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 8591257d74 [fix](nereids) parallel instance number is set to 1
incorrectly (#22748)
add b90a7748a6 [Feature](Job Schedule)implement Transient Task Register
(#22665)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/doris/catalog/Env.java | 29 +++++++---
.../TaskType.java} | 15 ++---
...{TimerTaskDisruptor.java => TaskDisruptor.java} | 45 +++++++++------
.../{TimerTaskEvent.java => TaskEvent.java} | 17 ++++--
...TaskExpirationHandler.java => TaskHandler.java} | 64 ++++++++++++++++------
.../doris/scheduler/exception/JobException.java | 4 ++
...askExecutor.java => TransientTaskExecutor.java} | 13 +++--
.../job/{DorisTimerTask.java => TimerJobTask.java} | 16 +++---
.../{AsyncJobManager.java => TimerJobManager.java} | 15 ++---
.../scheduler/manager/TransientTaskManager.java | 62 +++++++++++++++++++++
.../ExportTaskRegister.java} | 31 ++++++-----
.../TimerJobRegister.java} | 33 ++++++-----
...askRegister.java => TransientTaskRegister.java} | 9 +--
...skDisruptorTest.java => TaskDisruptorTest.java} | 20 ++++---
...obManagerTest.java => TimerJobManagerTest.java} | 28 ++++++----
15 files changed, 267 insertions(+), 134 deletions(-)
copy
fe/fe-core/src/main/java/org/apache/doris/scheduler/{registry/MemoryTaskRegister.java
=> constants/TaskType.java} (72%)
rename
fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/{TimerTaskDisruptor.java
=> TaskDisruptor.java} (72%)
rename
fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/{TimerTaskEvent.java
=> TaskEvent.java} (73%)
rename
fe/fe-core/src/main/java/org/apache/doris/scheduler/disruptor/{TimerTaskExpirationHandler.java
=> TaskHandler.java} (69%)
copy
fe/fe-core/src/main/java/org/apache/doris/scheduler/executor/{MemoryTaskExecutor.java
=> TransientTaskExecutor.java} (83%)
rename
fe/fe-core/src/main/java/org/apache/doris/scheduler/job/{DorisTimerTask.java =>
TimerJobTask.java} (73%)
rename
fe/fe-core/src/main/java/org/apache/doris/scheduler/manager/{AsyncJobManager.java
=> TimerJobManager.java} (97%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/scheduler/manager/TransientTaskManager.java
rename
fe/fe-core/src/main/java/org/apache/doris/scheduler/{executor/MemoryTaskExecutor.java
=> registry/ExportTaskRegister.java} (54%)
rename
fe/fe-core/src/main/java/org/apache/doris/scheduler/{AsyncJobRegister.java =>
registry/TimerJobRegister.java} (77%)
rename
fe/fe-core/src/main/java/org/apache/doris/scheduler/registry/{MemoryTaskRegister.java
=> TransientTaskRegister.java} (77%)
rename
fe/fe-core/src/test/java/org/apache/doris/scheduler/disruptor/{TimerTaskDisruptorTest.java
=> TaskDisruptorTest.java} (79%)
rename
fe/fe-core/src/test/java/org/apache/doris/scheduler/disruptor/{AsyncJobManagerTest.java
=> TimerJobManagerTest.java} (86%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
