-
Notifications
You must be signed in to change notification settings - Fork 314
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
[ARCTIC-1095][AMS] Add the sequence number for the native iceberg table when the major optimizing commit #1101
Conversation
Adding the sequence number in the plan when the major commit for the native iceberg table
@hzluting Hi, When committing major optimizing on an iceberg format table for one single partition, will the replaced delete files be deleted as there are other data files under other partitions which's sequence number is lower than replaced ones? |
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
OK, I will add the removing DeleteFiles. |
ams/ams-server/src/main/java/com/netease/arctic/ams/server/optimize/IcebergOptimizeCommit.java
Outdated
Show resolved
Hide resolved
ams/ams-server/src/main/java/com/netease/arctic/ams/server/optimize/IcebergOptimizeCommit.java
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.
* [ARCTIC-1062][AMS]Terminal support config spark properties in the local model (#1094) * terminal support config spark properties in the local model --------- Co-authored-by: jinsilei <jinsilei@corp.netease.com> * [AMS][Improvement]: Support set login user and login password in config yaml file (#1086) * Support set login user and login password in config yaml file * [ARCTIC-1091] Browser tab does not display Arctic's icon (#1092) fix-1091 Co-authored-by: shendanfeng01 <shendanfeng01@corp.netease.com> * [ARCTIC-1090][AMS]:Terminal support add hadoop conf when use native iceberg (#1099) * terminal supoort hadoop conf --------- Co-authored-by: jinsilei <jinsilei@corp.netease.com> * [ARCTIC-1093] Self-Optimizing scan files from metadata instead of from file info cache (#1100) * fix-1093 optimize use TableScan * modify OptimizeIntegrationTest for TestHiveSupport Table * 1.remove checking any tasks running during the plan 2.remove checking table changed during the plan and check it before scan files 3.AbstractIcebergOptimizePlan use the correct currentSnapshot 4.import OptimizePlanResult to to encapsulate the plan result * [hotfix] Lower the log level in ShuffleSplitAssigner (#1106) * [ARCTIC-1095][AMS] Add the sequence number for the native iceberg table when the major optimizing commit (#1101) * fix #1095 Adding the sequence number in the plan when the major commit for the native iceberg table --------- Co-authored-by: luting <dylzlt93299@gmail.com> * [ARCTIC-924][Hive] When AMS runs for a period of time and then cannot connect to HMS (#1054) --------- Co-authored-by: shendanfeng01 <shendanfeng01@corp.netease.com> --------- Co-authored-by: PlanetWalker <52364847+hellojinsilei@users.noreply.github.com> Co-authored-by: jinsilei <jinsilei@corp.netease.com> Co-authored-by: wangzeyu <hameizi369@gmail.com> Co-authored-by: shendanfengg <109209550+shendanfengg@users.noreply.github.com> Co-authored-by: shendanfeng01 <shendanfeng01@corp.netease.com> Co-authored-by: Xianxun Ye <yxx_cmhd@163.com> Co-authored-by: luting <1004611953@qq.com> Co-authored-by: luting <dylzlt93299@gmail.com>
…le when the major optimizing commit (apache#1101) * fix apache#1095 Adding the sequence number in the plan when the major commit for the native iceberg table * fix code review * add comment --------- Co-authored-by: luting <dylzlt93299@gmail.com> (cherry picked from commit 7c520e0)
…le when the major optimizing commit (apache#1101) * fix apache#1095 Adding the sequence number in the plan when the major commit for the native iceberg table * fix code review * add comment --------- Co-authored-by: luting <dylzlt93299@gmail.com>
Why are the changes needed?
fix #1095
Brief change log
How 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