This is an automated email from the ASF dual-hosted git repository.
diwu pushed a change to branch streaming-job-dev
in repository https://gitbox.apache.org/repos/asf/doris.git
from 4c6f13cb646 [Feature](WIP) add S3 Stream job split offset (#55927)
add 991de2db8f0 [Feature](WIP) Fix streaming job problem (#55949)
No new revisions were added by this update.
Summary of changes:
.../org/apache/doris/job/base/AbstractJob.java | 5 ++--
.../TimerJobEvent.java => common/JobUtils.java} | 23 ++++++--------
.../doris/job/executor/DispatchTaskHandler.java | 12 ++------
.../doris/job/executor/TimerJobSchedulerTask.java | 4 +--
.../insert/streaming/StreamingInsertJob.java | 34 ++++++++++++++-------
.../insert/streaming/StreamingInsertTask.java | 35 ++++++++++++++--------
.../streaming/StreamingJobSchedulerTask.java | 3 +-
.../job/offset/s3/S3SourceOffsetProvider.java | 22 ++++++++------
.../apache/doris/job/scheduler/JobScheduler.java | 7 +++--
.../job/scheduler/StreamingTaskScheduler.java | 5 ++--
.../trees/plans/commands/info/CreateJobInfo.java | 1 +
.../commands/insert/InsertIntoTableCommand.java | 3 --
12 files changed, 86 insertions(+), 68 deletions(-)
copy
fe/fe-core/src/main/java/org/apache/doris/job/{disruptor/TimerJobEvent.java =>
common/JobUtils.java} (70%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
