-
Notifications
You must be signed in to change notification settings - Fork 113
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
Fixes flaky continuous transforms and shrink tests #340
Conversation
Signed-off-by: Clay Downs <[email protected]>
Codecov Report
@@ Coverage Diff @@
## main #340 +/- ##
============================================
- Coverage 75.16% 75.04% -0.12%
+ Complexity 2144 2135 -9
============================================
Files 262 262
Lines 12434 12444 +10
Branches 1966 1966
============================================
- Hits 9346 9339 -7
- Misses 2022 2032 +10
- Partials 1066 1073 +7
Continue to review full report at Codecov.
|
Signed-off-by: Clay Downs <[email protected]>
fun getDiskSettings(clusterSettings: ClusterSettings): Settings { | ||
return Settings.builder().put( |
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.
What's the purpose of this (creating this almost empty Settings instance instead of passing the one that presumably has all the settings)?
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'm wondering the reason to do this is previously the settings passed in to DiskThresholdSettings
are not right? The right way is to extract from clusterSettings?
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 previously used the settings object from the step context, as I had the same assumption that it would have all of the settings. Actually, the settings object only contains the settings initially passed into the runner, it does not seem to consume updates from the cluster settings automatically. To get up to date settings, we need to extract them from the clusterSettings. I wonder why we have this settings object in the step context at all, as these out of date settings aren't very useful.
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.
Makes sense, I agree we need to remove settings from step context and only use clusterSettings to get update-to-date setting values.
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.
Got it, maybe @thalurur has some input on it or it might have just been a miss that we were passing in a snapshot of the settings.
* fixes flaky tests Signed-off-by: Clay Downs <[email protected]> * Deletes data stream manually Signed-off-by: Clay Downs <[email protected]> (cherry picked from commit 74dac63)
* fixes flaky tests Signed-off-by: Clay Downs <[email protected]> * Deletes data stream manually Signed-off-by: Clay Downs <[email protected]> (cherry picked from commit 74dac63) Co-authored-by: Clay Downs <[email protected]>
…t#340) * fixes flaky tests Signed-off-by: Clay Downs <[email protected]> * Deletes data stream manually Signed-off-by: Clay Downs <[email protected]>
…t#340) * fixes flaky tests Signed-off-by: Clay Downs <[email protected]> * Deletes data stream manually Signed-off-by: Clay Downs <[email protected]>
Signed-off-by: Clay Downs [email protected]
Issue #, if available:
NA
Description of changes:
CheckList:
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check here.