-
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
input_chunk: handle filter_do edge case #8229
input_chunk: handle filter_do edge case #8229
Conversation
I tried to add a test for this similar to my last PR, but unfortunately the test's mechanism for reading total records doesn't have enough granularity to get exact record counts and make sure that it's a precise expected number. |
flb_filter_do may modify the input chunk's total records, meaning that if there is a filter in the pipeline the total records could be double-counted which breaks anything that relies on and event chunk's `total_records`. Signed-off-by: braydonk <[email protected]>
96cc568
to
37cb10d
Compare
Clarify comment to demonstrate that flb_filter_do actually overwrites the value not just changing it. Signed-off-by: braydonk <[email protected]>
macos unit test failures are flakes. |
@leonardo-albertovich bumping this, fixes an edge case I missed in the last PR. |
@edsiper @leonardo-albertovich any chance of getting some eyes on this? |
flb_filter_do
may modify the input chunk's total records, meaning that if there is a filter in the pipeline the total records could be double-counted which breaks anything that relies on an event chunk'stotal_records
.Enter
[N/A]
in the box, if an item is not applicable to your change.Testing
Before we can approve your change; please submit the following in a comment:
If this is a change to packaging of containers or native binaries then please confirm it works for all targets.
ok-package-test
label to test for all targets (requires maintainer to do).Documentation
Backporting
Fluent Bit is licensed under Apache 2.0, by submitting this pull request I understand that this code will be released under the terms of that license.