-
Notifications
You must be signed in to change notification settings - Fork 1.9k
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
[Enhancement] Loading task should abort transaction if fail because of timeout #51939
Conversation
[BE Incremental Coverage Report]❌ fail : 1 / 5 (20.00%) file detail
|
…timeout Signed-off-by: PengFei Li <[email protected]>
Quality Gate passedIssues Measures |
[Java-Extensions Incremental Coverage Report]✅ pass : 0 / 0 (0%) |
[FE Incremental Coverage Report]✅ pass : 24 / 25 (96.00%) file detail
|
|
||
public class LoadErrorUtils { | ||
|
||
public static class ErrorMeta { |
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.
public static class ErrorMeta { | |
private static class ErrorMeta { |
@Mergifyio backport branch-3.3 |
@Mergifyio backport branch-3.2 |
@Mergifyio backport branch-3.1 |
✅ Backports have been created
|
✅ Backports have been created
|
✅ Backports have been created
|
…f timeout (#51939) Signed-off-by: PengFei Li <[email protected]> (cherry picked from commit 73172c3)
…f timeout (#51939) Signed-off-by: PengFei Li <[email protected]> (cherry picked from commit 73172c3) # Conflicts: # fe/fe-core/src/test/java/com/starrocks/load/loadv2/BrokerLoadJobTest.java
…f timeout (#51939) Signed-off-by: PengFei Li <[email protected]> (cherry picked from commit 73172c3)
…f timeout (StarRocks#51939) Signed-off-by: PengFei Li <[email protected]>
…f timeout (backport #51939) (#52010) Co-authored-by: PengFei Li <[email protected]>
…f timeout (backport #51939) (#52012) Co-authored-by: PengFei Li <[email protected]>
…f timeout (backport #51939) (#52054) Signed-off-by: PengFei Li <[email protected]>
…f timeout (StarRocks#51939) Signed-off-by: PengFei Li <[email protected]>
…f timeout (StarRocks#51939) Signed-off-by: PengFei Li <[email protected]>
…f timeout (StarRocks#51939) Signed-off-by: PengFei Li <[email protected]> Signed-off-by: zhiminr.ren <[email protected]>
Why I'm doing:
In #38183, broker load will retry if loading task fails because of timeout. But currently the retry will be executed until transaction timeouts even if the loading task has failed before transaction timeout. For example, the task fails because BE BRPC timeouts which is half of transaction timeout by default, and the load should retry immediately after the task fails.
What I'm doing:
If the task fails because of timeout, abort the transaction so that it can try as soon as possible
Fixes #issue
What type of PR is this:
Does this PR entail a change in behavior?
If yes, please specify the type of change:
Checklist:
Bugfix cherry-pick branch check: