diff options
| author | Jon Marius Venstad <jonmv@users.noreply.github.com> | 2021-06-24 14:28:15 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-06-24 14:28:15 +0200 |
| commit | 043bab713b6106a2b633d87e8b1ca2c9a68ee6bd (patch) | |
| tree | a676ac281a854a65d11ba11a63e00501d641b578 /vespa-hadoop | |
| parent | f0aeaa8e8d59a2102438a85ec7790de10f6f1ec0 (diff) | |
specify it's the max
Diffstat (limited to 'vespa-hadoop')
| -rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java index 919f2206f7e..84dbe919c5c 100644 --- a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java +++ b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java @@ -138,7 +138,7 @@ public class VespaRecordWriter extends RecordWriter<Object, Object> { List<URI> endpoints = endpointUris(config); log.info("Using endpoints " + endpoints); int streamsPerConnection = streamsPerConnection(config); - log.log(Level.INFO, "Using {0} streams per connection", new Object[] {streamsPerConnection}); + log.log(Level.INFO, "Using {0} max streams per connection", new Object[] {streamsPerConnection}); log.log(Level.INFO, "Using {0} connections", new Object[] {config.numConnections()}); FeedClientBuilder feedClientBuilder = FeedClientBuilder.create(endpoints) .setConnectionsPerEndpoint(config.numConnections()) |