-
Notifications
You must be signed in to change notification settings - Fork 2.4k
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
[pkg/stanza/operator/transformer/recombine] Add max_unmatched_batch_size to recombine operator #32168
[pkg/stanza/operator/transformer/recombine] Add max_unmatched_batch_size to recombine operator #32168
Conversation
1010656
to
2513520
Compare
I'm still testing this, I'll let you know when it is ready for review. |
065619f
to
5330811
Compare
It is ready for review @djaglowski Random failures of tests were caused by missing initialization of The failure of coverage test doesn't look as related to my changes, it looks like as related to codecov/codecov-action#1359 |
5330811
to
547c1df
Compare
@sumo-drosiek please take a look also ;) |
547c1df
to
d065193
Compare
…ize to recombine operator
…_unmatched_batch_size tests to isolate the root cause of potential problems overwrite_with config option is tested in other test cases
… in tests with is_last_entry where last entry matches regular expression to avoid of time condition in flushing
ef530d6
to
39e0880
Compare
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. It would be nice to have good technical configuration documentation for this operator, as logic is rather complex 🙈
…ize - initialize value of matchDetected for new batch fix test cases for max_unmatched_batch_size - some had incorrect expected values
39e0880
to
a6bc569
Compare
Description: Add a new max_unmatched_batch_size config parameter to configure the maximum number of consecutive entries that will be combined into a single entry before the match occurs
Link to tracking Issue: #31653
Testing: unit tests, manual tests
Documentation: Add description of the new config option
Changes from #32144 with improvements in tests