Support feed over http using vespa-feed-client

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());
     }
 }