fix test error

sokui · Dec 13, 2024 · 28d71f3 · 28d71f3
1 parent 0dfcda6
commit 28d71f3
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...n/java/org/apache/hadoop/ozone/om/request/s3/multipart/S3MultipartUploadAbortRequest.java b/...n/java/org/apache/hadoop/ozone/om/request/s3/multipart/S3MultipartUploadAbortRequest.java
@@ -157,13 +157,18 @@ public OMClientResponse validateAndUpdateCache(OzoneManager ozoneManager, TermIn
       // If there is no entry in openKeyTable, then there is no multipart
       // upload initiated for this key.
       if (omKeyInfo == null) {
-        throw new OMException("Abort Multipart Upload Failed: volume: " +
+        throw new OMException("Abort Multipart Upload Failed (omKeyInfo not found): volume: " +
             requestedVolume + "bucket: " + requestedBucket + "key: " + keyName,
             OMException.ResultCodes.NO_SUCH_MULTIPART_UPLOAD_ERROR);
       }
 
       multipartKeyInfo = omMetadataManager.getMultipartInfoTable()
           .get(multipartKey);
+      if (multipartKeyInfo == null) {
+        throw new OMException("Abort Multipart Upload Failed (multipartKeyInfo not found): volume: " +
+                requestedVolume + "bucket: " + requestedBucket + "key: " + keyName,
+                OMException.ResultCodes.NO_SUCH_MULTIPART_UPLOAD_ERROR);
+      }
       multipartKeyInfo.setUpdateID(trxnLogIndex, ozoneManager.isRatisEnabled());
 
       // When abort uploaded key, we need to subtract the PartKey length from