diff options
Diffstat (limited to 'vespa-hadoop')
-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 7ad51a55bff..4cc93bfd538 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 @@ -29,6 +29,7 @@ import javax.xml.stream.events.StartElement; import javax.xml.stream.events.XMLEvent; import java.io.IOException; import java.io.StringReader; +import java.time.Duration; import java.util.List; import java.util.StringTokenizer; import java.util.concurrent.ThreadLocalRandom; @@ -116,7 +117,7 @@ public class VespaRecordWriter extends RecordWriter { feedParamsBuilder.setRoute(configuration.route()); feedParamsBuilder.setMaxSleepTimeMs(configuration.maxSleepTimeMs()); feedParamsBuilder.setMaxInFlightRequests(configuration.maxInFlightRequests()); - feedParamsBuilder.setLocalQueueTimeOut(3600*1000); //1 hour queue timeout + feedParamsBuilder.setLocalQueueTimeOut(Duration.ofMinutes(10).toMillis()); return feedParamsBuilder; } |