diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-24 14:04:15 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-06-24 14:04:15 +0200 |
commit | d28447178016595d77272cc29f1ba009317cf8a8 (patch) | |
tree | 4fb8c6393f8e203a7bec9df749d3f938725104e5 /vespa-hadoop | |
parent | d25995ae103887c9509cb8622429a50b9138a7f7 (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.java | 9 |
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); |