-
Notifications
You must be signed in to change notification settings - Fork 298
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
[AMORO-1883] Perform file filtering when adding files to PartitionEvaluator
instead of during splitting tasks
#1886
Conversation
PartitionEvaluator
instead of during splitting tasks
Codecov ReportPatch coverage:
Additional details and impacted files@@ Coverage Diff @@
## master #1886 +/- ##
============================================
- Coverage 50.83% 50.78% -0.05%
+ Complexity 3803 3802 -1
============================================
Files 479 479
Lines 25648 25645 -3
Branches 2611 2613 +2
============================================
- Hits 13038 13024 -14
- Misses 11443 11454 +11
Partials 1167 1167
Flags with carried forward coverage won't be shown. Click here to find out more.
☔ View full report in Codecov by Sentry. |
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 left some comments, PTAL.
ams/server/src/main/java/com/netease/arctic/server/optimizing/plan/AbstractPartitionPlan.java
Outdated
Show resolved
Hide resolved
ams/server/src/main/java/com/netease/arctic/server/optimizing/plan/AbstractPartitionPlan.java
Show resolved
Hide resolved
ams/server/src/main/java/com/netease/arctic/server/optimizing/plan/PartitionEvaluator.java
Show resolved
Hide resolved
...server/src/main/java/com/netease/arctic/server/optimizing/plan/CommonPartitionEvaluator.java
Outdated
Show resolved
Hide resolved
...server/src/main/java/com/netease/arctic/server/optimizing/plan/CommonPartitionEvaluator.java
Show resolved
Hide resolved
...server/src/main/java/com/netease/arctic/server/optimizing/plan/CommonPartitionEvaluator.java
Show resolved
Hide resolved
...server/src/main/java/com/netease/arctic/server/optimizing/plan/CommonPartitionEvaluator.java
Show resolved
Hide resolved
...server/src/main/java/com/netease/arctic/server/optimizing/plan/CommonPartitionEvaluator.java
Show resolved
Hide resolved
Refer to issue #1866 |
ams/server/src/main/java/com/netease/arctic/server/optimizing/plan/OptimizingEvaluator.java
Outdated
Show resolved
Hide resolved
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.
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.
…aluator` instead of during splitting tasks (apache#1886) * optimizing plan: filter when add files * fix some comment * cache reachHiveRefreshInterval * add docs * rename to reservedDeleteFiles * add return false * move reachFullInterval to constructor * set properties first * add some check code * add docs for PartitionEvaluator * fix add properties first * remove addPartitionProperties from PartitionEvaluator, add it to constructor * remove all files if optimizing is not enabled * fix reservedDeleteFiles
Why are the changes needed?
fix #1883
Brief change log
PartitionEvaluator
andAbstractPartitionPlan
taskNeedExecute
after splitting tasksaddPartitionProperties
fromPartitionEvaluator
, add it to the constructorHow was this patch tested?
Add some test cases that check the changes thoroughly including negative and positive cases if possible
Add screenshots for manual tests if appropriate
Run test locally before making a pull request
Documentation