Exception Exceptions.InflightLimitExceededException (3.11.0)

public static class Exceptions.InflightLimitExceededException extends StatusRuntimeException

If FlowController.LimitExceededBehavior is set to Block and inflight limit is exceeded, this exception will be thrown. If it is just a spike, you may retry the request. Otherwise, you can increase the inflight limit or create more StreamWriter to handle your traffic.

Constructors

InflightLimitExceededException(Status grpcStatus, String writerId, long currentLimit)

protected InflightLimitExceededException(Status grpcStatus, String writerId, long currentLimit)
Parameters
Name Description
grpcStatus io.grpc.Status
writerId String
currentLimit long

Methods

getCurrentLimit()

public long getCurrentLimit()
Returns
Type Description
long

getWriterId()

public String getWriterId()
Returns
Type Description
String