This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from f81fc0463ce [Performance](Variant) Improve load performance for
variant type (#33890)
add 76db8c2880d [fix](routine-load) do not schedule task when there is no
data (#34540)
No new revisions were added by this update.
Summary of changes:
be/src/runtime/routine_load/data_consumer.cpp | 45 +++++++++++++
be/src/runtime/routine_load/data_consumer.h | 3 +
.../routine_load/routine_load_task_executor.cpp | 23 +++++++
.../routine_load/routine_load_task_executor.h | 4 ++
be/src/service/internal_service.cpp | 18 ++++-
.../apache/doris/datasource/kafka/KafkaUtil.java | 76 ++++++++++++++++++++++
.../load/routineload/KafkaRoutineLoadJob.java | 37 +++++++----
.../load/routineload/KafkaRoutineLoadJobTest.java | 15 +++++
.../doris/load/routineload/RoutineLoadJobTest.java | 15 +++++
gensrc/proto/internal_service.proto | 2 +
.../routine_load/test_routine_load_schedule.out | 23 +++++++
...{test_where_condition.csv => test_schedule.csv} | 0
...on.groovy => test_routine_load_schedule.groovy} | 64 ++++++++++++++----
13 files changed, 299 insertions(+), 26 deletions(-)
create mode 100644
regression-test/data/load_p0/routine_load/test_routine_load_schedule.out
copy
regression-test/suites/load_p0/routine_load/data/{test_where_condition.csv =>
test_schedule.csv} (100%)
copy
regression-test/suites/load_p0/routine_load/{test_routine_load_condition.groovy
=> test_routine_load_schedule.groovy} (76%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
