database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](hive-writer) Fixed the issue where uncompletedMpuPendingUploads did not remove objects correctly. (#37173)

Browse Source 
Backport #36905.
This commit is contained in:
Qi Chen
2024-07-03 11:09:46 +08:00
committed by GitHub
parent e857680661
commit fb642d0227
1 changed files with 18 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java
View File

@ -103,6 +103,24 @@ public class HMSTransaction implements Transaction {
this.s3MPUPendingUpload = s3MPUPendingUpload;
this.path = path;
}
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
UncompletedMpuPendingUpload that = (UncompletedMpuPendingUpload) o;
return Objects.equals(s3MPUPendingUpload, that.s3MPUPendingUpload) && Objects.equals(path,
that.path);
}
@Override
public int hashCode() {
return Objects.hash(s3MPUPendingUpload, path);
}
}
private Set<UncompletedMpuPendingUpload> uncompletedMpuPendingUploads = new HashSet<>();