This is an automated email from the ASF dual-hosted git repository. szetszwo pushed a commit to branch branch-2_readIndex in repository https://gitbox.apache.org/repos/asf/ratis.git
commit 252446070a1461ebc8e807b78f4aaad759700507 Author: William Song <[email protected]> AuthorDate: Thu Mar 9 10:53:13 2023 +0800 RATIS-1811. Improve StreamObserver's log messages (#849) (cherry picked from commit 1ca77a1ca3736fab666094ef79048d338d966554) --- .../java/org/apache/ratis/grpc/server/GrpcServerProtocolService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcServerProtocolService.java b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcServerProtocolService.java index 8a58cdd9c..08386f83c 100644 --- a/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcServerProtocolService.java +++ b/ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcServerProtocolService.java @@ -148,7 +148,7 @@ class GrpcServerProtocolService extends RaftServerProtocolServiceImplBase { } @Override public void onError(Throwable t) { - GrpcUtil.warn(LOG, () -> getId() + ": installSnapshot onError, lastRequest: " + getPreviousRequestString(), t); + GrpcUtil.warn(LOG, () -> getId() + ": "+ op + " onError, lastRequest: " + getPreviousRequestString(), t); if (isClosed.compareAndSet(false, true)) { Status status = Status.fromThrowable(t); if (status != null && status.getCode() != Status.Code.CANCELLED) {
