This is an automated email from the ASF dual-hosted git repository.
sumitagrawal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 0552b5a049 HDDS-9074. Ozone Manager terminated in CreateKey request
due to bucket not found. (#5110)
0552b5a049 is described below
commit 0552b5a049a415ebd7f8cfb471301c7d02359b4d
Author: ashishkumar50 <[email protected]>
AuthorDate: Tue Jul 25 14:10:08 2023 +0530
HDDS-9074. Ozone Manager terminated in CreateKey request due to bucket not
found. (#5110)
---
.../hadoop/ozone/om/ratis/OzoneManagerStateMachine.java | 17 +++++++++++++++++
1 file changed, 17 insertions(+)
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerStateMachine.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerStateMachine.java
index 62c387f332..ddaa066373 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerStateMachine.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/ratis/OzoneManagerStateMachine.java
@@ -41,6 +41,7 @@ import org.apache.hadoop.ozone.om.OzoneManager;
import org.apache.hadoop.ozone.om.OzoneManagerPrepareState;
import org.apache.hadoop.ozone.om.exceptions.OMException;
import org.apache.hadoop.ozone.om.helpers.OMRatisHelper;
+import org.apache.hadoop.ozone.om.ratis.utils.OzoneManagerRatisUtils;
import org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos;
import org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos
.OMRequest;
@@ -566,6 +567,9 @@ public class OzoneManagerStateMachine extends
BaseStateMachine {
try {
return handler.handleWriteRequest(request,
trxLogIndex).getOMResponse();
+ } catch (IOException e) {
+ LOG.warn("Failed to write, Exception occurred ", e);
+ return createErrorResponse(request, e);
} catch (Throwable e) {
// For any Runtime exceptions, terminate OM.
String errorMessage = "Request " + request + " failed with exception";
@@ -574,6 +578,19 @@ public class OzoneManagerStateMachine extends
BaseStateMachine {
return null;
}
+ private OMResponse createErrorResponse(
+ OMRequest omRequest, IOException exception) {
+ OMResponse.Builder omResponse = OMResponse.newBuilder()
+ .setStatus(OzoneManagerRatisUtils.exceptionToResponseStatus(exception))
+ .setCmdType(omRequest.getCmdType())
+ .setTraceID(omRequest.getTraceID())
+ .setSuccess(false);
+ if (exception.getMessage() != null) {
+ omResponse.setMessage(exception.getMessage());
+ }
+ return omResponse.build();
+ }
+
/**
* Update lastAppliedIndex term and it's corresponding term in the
* stateMachine.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
