diff options
| -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()) |