-
Notifications
You must be signed in to change notification settings - Fork 1.6k
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
[exporter][batching][chore] record batch creation time #12752
base: main
Are you sure you want to change the base?
Conversation
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## main #12752 +/- ##
==========================================
- Coverage 91.45% 91.45% -0.01%
==========================================
Files 483 483
Lines 26605 26604 -1
==========================================
- Hits 24332 24331 -1
Misses 1791 1791
Partials 482 482 ☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
if !forceFlush && time.Since(qb.currentBatch.created) < qb.cfg.FlushTimeout { | ||
qb.currentBatchMu.Unlock() | ||
return | ||
} |
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.
This mean that we no longer do flush every FlushTimeout
, but somewhere between [FlushTimeout, 2*FlushTimeout]
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.
Agreed. Is changing to a Ticker needed?
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.
I see what you mean.
I was trying to use a single time keeper for all batches, but if we want to control the flush timeout more precisely, we could keep a separate timer for each batch instead
145bde3
to
4b42af5
Compare
Description
This PR
Link to tracking issue
#12473
Testing
Documentation