fix compile error

Alluxio · Mar 12, 2024 · aab5259 · aab5259
1 parent f50e474
commit aab5259
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/core/server/worker/src/main/java/alluxio/worker/grpc/BlockReadHandler.java b/core/server/worker/src/main/java/alluxio/worker/grpc/BlockReadHandler.java
@@ -466,15 +466,15 @@ private void runInternal() {
       }
       if (error != null) {
         try {
-          boolean success = !cancel && error == null;
-          completeRequest(mContext, success);
+          completeRequest(mContext, false);
         } catch (Exception e) {
           LOG.error("Failed to close the request.", e);
         }
         replyError(error);
       } else if (eof || cancel) {
         try {
-          completeRequest(mContext);
+          boolean success = !cancel;
+          completeRequest(mContext, success);
         } catch (Exception e) {
           LogUtils.warnWithException(LOG, "Exception occurred while completing read request, "
                   + "EOF/CANCEL sessionId: {}. {}", mContext.getRequest().getSessionId(),