summaryrefslogtreecommitdiffstats
path: root/vespa-hadoop
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2021-06-24 14:04:15 +0200
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2021-06-24 14:04:15 +0200
commitd28447178016595d77272cc29f1ba009317cf8a8 (patch)
tree4fb8c6393f8e203a7bec9df749d3f938725104e5 /vespa-hadoop
parentd25995ae103887c9509cb8622429a50b9138a7f7 (diff)
Add logging of most important config parameters
Diffstat (limited to 'vespa-hadoop')
-rw-r--r--vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java9
1 files changed, 7 insertions, 2 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 1c370b14b82..6540aec342d 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
@@ -137,9 +137,14 @@ public class VespaRecordWriter extends RecordWriter<Object, Object> {
if (config.dryrun()) {
return new DryrunClient();
} else {
- FeedClientBuilder feedClientBuilder = FeedClientBuilder.create(endpointUris(config))
+ 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} connections", new Object[] {config.numConnections()});
+ FeedClientBuilder feedClientBuilder = FeedClientBuilder.create(endpoints)
.setConnectionsPerEndpoint(config.numConnections())
- .setMaxStreamPerConnection(streamsPerConnection(config))
+ .setMaxStreamPerConnection(streamsPerConnection)
.setRetryStrategy(retryStrategy(config));
onFeedClientInitialization(feedClientBuilder);