grpc runtime_error ai_generated true

CANCELLED: grpc: client-side stream aborted by client

ID: grpc/grpc-client-side-stream-abort

Also available as: JSON · Markdown · 中文

85%Fix Rate

82%Confidence

1Evidence

2024-01-10First Seen

Version Compatibility

Version	Status	Introduced	Deprecated	Notes
grpc-go 1.62.0	active	—	—	—
grpc-python 1.60.0	active	—	—	—
grpc-node 1.10.0	active	—	—	—

Root Cause

Client explicitly closed or cancelled the stream before the server finished processing, often due to premature context cancellation or stream.CloseSend() misuse.

generic

中文

客户端在服务器完成处理之前显式关闭或取消了流，通常是由于过早的上下文取消或 stream.CloseSend() 的误用。

Official Documentation

https://grpc.io/docs/languages/go/basics/#client-side-streaming-rpc

Workarounds

90% success Ensure the client does not call stream.CloseSend() before receiving all server responses. In gRPC-Go, use a proper pattern: stream, err := client.StreamingMethod(ctx) // Send all messages stream.CloseSend() // Then receive all responses for { resp, err := stream.Recv() if err == io.EOF { break } }
```
Ensure the client does not call stream.CloseSend() before receiving all server responses. In gRPC-Go, use a proper pattern:
  stream, err := client.StreamingMethod(ctx)
  // Send all messages
  stream.CloseSend()
  // Then receive all responses
  for {
      resp, err := stream.Recv()
      if err == io.EOF { break }
  }
```
80% success Add a defer cancel() after creating the context to ensure proper cleanup without premature cancellation: ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) defer cancel() stream, _ := client.StreamingMethod(ctx) // Use stream // cancel() will be called when function returns, not before stream completes
```
Add a defer cancel() after creating the context to ensure proper cleanup without premature cancellation:
  ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
  defer cancel()
  stream, _ := client.StreamingMethod(ctx)
  // Use stream
  // cancel() will be called when function returns, not before stream completes
```

中文步骤

Ensure the client does not call stream.CloseSend() before receiving all server responses. In gRPC-Go, use a proper pattern:
  stream, err := client.StreamingMethod(ctx)
  // Send all messages
  stream.CloseSend()
  // Then receive all responses
  for {
      resp, err := stream.Recv()
      if err == io.EOF { break }
  }

Add a defer cancel() after creating the context to ensure proper cleanup without premature cancellation:
  ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
  defer cancel()
  stream, _ := client.StreamingMethod(ctx)
  // Use stream
  // cancel() will be called when function returns, not before stream completes

Dead Ends

Common approaches that don't work:

80% fail
The error is caused by explicit cancellation or stream abort, not timeout; extending timeout doesn't prevent premature CloseSend().
95% fail
The stream is already closed; server cannot send responses, leading to resource leaks and inconsistent state.