This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new fb642d02270 [Fix](hive-writer) Fixed the issue where
`uncompletedMpuPendingUploads` did not remove objects correctly. (#37173)
fb642d02270 is described below
commit fb642d022701aa1db529e17f09d622b42689c899
Author: Qi Chen <[email protected]>
AuthorDate: Wed Jul 3 11:09:46 2024 +0800
[Fix](hive-writer) Fixed the issue where `uncompletedMpuPendingUploads` did
not remove objects correctly. (#37173)
Backport #36905.
---
.../apache/doris/datasource/hive/HMSTransaction.java | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java
index 824af6996a9..d883b9dc786 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSTransaction.java
@@ -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<>();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
