This is an automated email from the ASF dual-hosted git repository.
yangzhg pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git.
from e547e77 Fix variable dbName that is never used (#6802)
add 5ef3f59 [Optimize][RoutineLoad] Avoid sending tasks if there is no
data to be consumed (#6805)
No new revisions were added by this update.
Summary of changes:
be/src/runtime/routine_load/data_consumer.cpp | 29 +++++-
be/src/runtime/routine_load/data_consumer.h | 3 +
.../routine_load/routine_load_task_executor.cpp | 23 ++++-
.../routine_load/routine_load_task_executor.h | 3 +
be/src/service/internal_service.cpp | 18 +++-
conf/fe.conf | 2 +-
.../java/org/apache/doris/catalog/DiskInfo.java | 9 +-
.../main/java/org/apache/doris/common/Config.java | 2 +-
.../org/apache/doris/common/util/KafkaUtil.java | 70 +++++++++++++-
.../apache/doris/journal/bdbje/BDBJEJournal.java | 2 +-
.../load/routineload/KafkaRoutineLoadJob.java | 106 +++++++++++++++++----
.../doris/load/routineload/KafkaTaskInfo.java | 21 +++-
.../doris/load/routineload/RoutineLoadJob.java | 23 +++--
.../doris/load/routineload/RoutineLoadManager.java | 20 ++--
.../load/routineload/RoutineLoadTaskInfo.java | 4 +-
.../load/routineload/RoutineLoadTaskScheduler.java | 12 ++-
.../org/apache/doris/master/ReportHandler.java | 10 ++
.../main/java/org/apache/doris/system/Backend.java | 4 +
.../java/org/apache/doris/catalog/BackendTest.java | 11 ++-
.../load/routineload/RoutineLoadManagerTest.java | 2 +-
.../routineload/RoutineLoadTaskSchedulerTest.java | 2 +-
gensrc/proto/internal_service.proto | 3 +
thirdparty/vars.sh | 10 +-
23 files changed, 322 insertions(+), 67 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
