diff options
| -rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java | 3 |
1 files changed, 2 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 ecac9f67615..54de9e6c1c0 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 @@ -147,8 +147,9 @@ public class VespaRecordWriter extends RecordWriter<Object, Object> { } private static List<URI> endpointUris(VespaConfiguration config) { + String scheme = config.useSSL() ? "https" : "http"; return Arrays.stream(config.endpoint().split(",")) - .map(hostname -> URI.create(String.format("https://%s:%d/", hostname, config.defaultPort()))) + .map(hostname -> URI.create(String.format("%s://%s:%d/", scheme, hostname, config.defaultPort()))) .collect(toList()); } } |