-
Notifications
You must be signed in to change notification settings - Fork 3.3k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[fix](routine-load) fix routine load lag is negative #33846
Conversation
Thank you for your contribution to Apache Doris. Since 2024-03-18, the Document has been moved to doris-website. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
clang-tidy made some suggestions
b73c38b
to
beb937f
Compare
run buildall |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
clang-tidy made some suggestions
TeamCity be ut coverage result: |
run buildall |
TeamCity be ut coverage result: |
run buildall |
clang-tidy review says "All clean, LGTM! 👍" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
clang-tidy made some suggestions
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
clang-tidy made some suggestions
run buildall |
TPC-H: Total hot run time: 38649 ms
|
TPC-DS: Total hot run time: 185780 ms
|
ClickBench: Total hot run time: 29.81 s
|
Load test result on machine: 'aliyun_ecs.c7a.8xlarge_32C64G'
|
TeamCity be ut coverage result: |
613b034
to
ebb6755
Compare
run buildall |
TPC-H: Total hot run time: 38712 ms
|
TPC-DS: Total hot run time: 184165 ms
|
ClickBench: Total hot run time: 30.35 s
|
TeamCity be ut coverage result: |
ebb6755
to
6769561
Compare
run buildall |
TPC-H: Total hot run time: 39008 ms
|
TPC-DS: Total hot run time: 184905 ms
|
TPC-DS: Total hot run time: 183175 ms
|
ClickBench: Total hot run time: 30.41 s
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
PR approved by at least one committer and no changes requested. |
PR approved by anyone and no changes requested. |
fe/fe-core/src/main/java/org/apache/doris/load/routineload/KafkaRoutineLoadJob.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
* [fix](routine-load) fix routine load lag is negative (#33846) * fix merge error
Proposed changes
If the amount of data consumed during the consumption process exceeds the maximum offset of obtaining kafka before task scheduling, it will become a negative number.
To solve this problem, obtaining the maximum offset during transaction submission has two benefits:
Further comments
If this is a relatively large or complex change, kick off the discussion at dev@doris.apache.org by explaining why you chose the solution you did and what alternatives you considered, etc...