-
Notifications
You must be signed in to change notification settings - Fork 1.8k
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] make report audit statistics in sink operator asynchronous #48162
Conversation
Signed-off-by: luohaha <[email protected]>
it seems _is_audit_report_done in OlapTableSink is unnecessary? |
Yes, I think so, because we didn't handle report failure now, so there is no guarantee that the report will be successful |
Signed-off-by: luohaha <[email protected]>
[FE Incremental Coverage Report]✅ pass : 0 / 0 (0%) |
[BE Incremental Coverage Report]❌ fail : 4 / 7 (57.14%) file detail
|
@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
|
…ous (#48162) Signed-off-by: luohaha <[email protected]> (cherry picked from commit ca5a6db)
…ous (#48162) Signed-off-by: luohaha <[email protected]> (cherry picked from commit ca5a6db)
…ous (#48162) Signed-off-by: luohaha <[email protected]> (cherry picked from commit ca5a6db)
…ous (backport #48162) (#48584) Co-authored-by: Yixin Luo <[email protected]>
…ous (backport #48162) (#48583) Co-authored-by: Yixin Luo <[email protected]>
…ous (backport #48162) (#48582) Co-authored-by: Yixin Luo <[email protected]>
…ous (StarRocks#48162) Signed-off-by: luohaha <[email protected]>
Why I'm doing:
In this PR #38032, we already introduce a asynchronous audit statistics reporter, but it doesn't work because we set
done
flag when this job begin to be execute and if too many jobs waiting to be executed, it will still make sink operator hang waiting report statistics finish.What I'm doing:
Sink operator won't wait for audit statistics report.
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: