diff options
author | Jon Bratseth <bratseth@gmail.com> | 2020-04-16 11:14:09 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@gmail.com> | 2020-04-16 11:14:09 +0200 |
commit | 42c17ff03aede800278ce5f56a4124059bf29e7b (patch) | |
tree | 0a7781c2d58a6c7e7919a560fc24b000a01bfafb /vespa-http-client/src | |
parent | 748fcdf0901196fb6c7339ffdaf45bd47c56c78b (diff) |
Minor fixes
Diffstat (limited to 'vespa-http-client/src')
2 files changed, 2 insertions, 3 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java index f9279f429ff..d8efeea93bc 100644 --- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java +++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/EndpointIOException.java @@ -20,7 +20,7 @@ public class EndpointIOException extends IOException { this.endpoint = endpoint; } - /** Returns the endpoint, or the failure occurred before this was assigned to a unique endpoint */ + /** Returns the endpoint, or null if the failure occurred before this was assigned to a unique endpoint */ public Endpoint getEndpoint() { return endpoint; } } diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java index a6460c62375..44799e598b0 100644 --- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java +++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/core/communication/IOThread.java @@ -19,7 +19,6 @@ import java.util.List; import java.util.Optional; import java.util.Random; import java.util.concurrent.CountDownLatch; -import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import java.util.logging.Level; @@ -205,7 +204,7 @@ class IOThread implements Runnable, AutoCloseable { chunkSizeBytes += document.size(); pendingSize++; } - if (log.isLoggable(Level.FINE)) + if (log.isLoggable(Level.FINEST)) log.finest("Chunk has " + docsForSendChunk.size() + " docs with a size " + chunkSizeBytes + " bytes"); docsReceivedCounter.addAndGet(docsForSendChunk.size()); return docsForSendChunk; |