You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by wi...@apache.org on 2023/03/09 02:53:17 UTC
[ratis] branch master updated: RATIS-1811. Improve StreamObserver's log messages (#849)
This is an automated email from the ASF dual-hosted git repository.
williamsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git
The following commit(s) were added to refs/heads/master by this push:
new 1ca77a1ca RATIS-1811. Improve StreamObserver's log messages (#849)
1ca77a1ca is described below
commit 1ca77a1ca3736fab666094ef79048d338d966554
Author: William Song <48...@users.noreply.github.com>
AuthorDate: Thu Mar 9 10:53:13 2023 +0800
RATIS-1811. Improve StreamObserver's log messages (#849)
---
.../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) {