Exception Exceptions.InflightLimitExceededException (3.4.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
NameDescription
grpcStatusio.grpc.Status
writerIdString
currentLimitlong

Methods

getCurrentLimit()

public long getCurrentLimit()
Returns
TypeDescription
long

getWriterId()

public String getWriterId()
Returns
TypeDescription
String