diff options
| author | Tor Brede Vekterli <vekterli@yahoo-inc.com> | 2016-10-26 13:39:49 +0200 |
|---|---|---|
| committer | Tor Brede Vekterli <vekterli@yahoo-inc.com> | 2016-10-26 13:39:49 +0200 |
| commit | bbf080606d7d785c8a63c97c68fb7aafc7fa8bcd (patch) | |
| tree | 29604fc6331b61b11f777b72e75560efdae2ba42 /documentapi | |
| parent | 270f856209e8ed896b6d6b70b02794f82e152ce1 (diff) | |
Reduce log level for "unexpected" wrong distribution reply to debug
Client load can be rejected towards distributors even with a matching
cluster state version. This usually happens during a node fail-over
transition, where the target distributor will reject an operation
bound to a particular bucket if it does not own the bucket in _both_
the current and the next (transition target) state. Since it can happen
during normal operation and will happen per client operation, we keep
this as debug level to prevent spamming the logs.
Diffstat (limited to 'documentapi')
| -rw-r--r-- | documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/StoragePolicy.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/StoragePolicy.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/StoragePolicy.java index 809d10e80e9..fdb4b8f6339 100644 --- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/StoragePolicy.java +++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/StoragePolicy.java @@ -358,7 +358,12 @@ public class StoragePolicy extends ExternalSlobrokPolicy { " retrieved cluster state version " + newState.getVersion() + " which was the state we used to calculate distributor as target last time."; reply.getTrace().trace(1, msg); - log.log(LogLevel.WARNING, msg); + // Client load can be rejected towards distributors even with a matching cluster state version. + // This usually happens during a node fail-over transition, where the target distributor will + // reject an operation bound to a particular bucket if it does not own the bucket in _both_ + // the current and the next (transition target) state. Since it can happen during normal operation + // and will happen per client operation, we keep this as debug level to prevent spamming the logs. + log.log(LogLevel.DEBUG, msg); } else if (newState.getVersion() > context.usedState.getVersion()) { if (reply.getTrace().shouldTrace(1)) { reply.getTrace().trace(1, "Message sent to distributor " + context.calculatedDistributor + |