From aab52594ba90ed39a9c7a069ea8ab860dea41d4a Mon Sep 17 00:00:00 2001 From: Jianjian Date: Tue, 12 Mar 2024 15:09:47 -0700 Subject: [PATCH] fix compile error --- .../src/main/java/alluxio/worker/grpc/BlockReadHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 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 index 4286a658ef43..3e5abac7edc5 100644 --- 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(),