summaryrefslogtreecommitdiffstats
path: root/vespa-hadoop
diff options
context:
space:
mode:
authorKristian Aune <kraune@oath.com>2017-11-17 09:54:39 +0100
committerKristian Aune <kraune@oath.com>2017-11-17 09:54:39 +0100
commitf3b0da051259f1d343402f6c3f14cc6644dd0e98 (patch)
treec4ee6c0ed0d512b56ea5f8b46a23344daaaf8bf8 /vespa-hadoop
parent82a979fbd3eb53bece2ffa27a05e762e03154d73 (diff)
rename method, optimize import
Diffstat (limited to 'vespa-hadoop')
-rw-r--r--vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java5
-rw-r--r--vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/util/VespaConfiguration.java4
2 files changed, 4 insertions, 5 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 db0fada990f..75607be3dfd 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
@@ -35,7 +35,6 @@ import com.yahoo.vespa.http.client.config.Endpoint;
import com.yahoo.vespa.http.client.config.FeedParams;
import com.yahoo.vespa.http.client.config.FeedParams.DataFormat;
import com.yahoo.vespa.http.client.config.SessionParams;
-import org.apache.hadoop.mapreduce.v2.app.job.Task;
/**
* VespaRecordWriter sends the output &lt;key, value&gt; to one or more Vespa
@@ -133,8 +132,8 @@ public class VespaRecordWriter extends RecordWriter {
}
private void initialize() {
- if (!configuration.dryrun() && configuration.randomSartupSleepMs() > 0) {
- int delay = new Random().nextInt(configuration.randomSartupSleepMs());
+ if (!configuration.dryrun() && configuration.randomStartupSleepMs() > 0) {
+ int delay = new Random().nextInt(configuration.randomStartupSleepMs());
log.info("VespaStorage: Delaying startup by " + delay + " ms");
try {
Thread.sleep(delay);
diff --git a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/util/VespaConfiguration.java b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/util/VespaConfiguration.java
index a05d2a35e4f..99928fd80fb 100644
--- a/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/util/VespaConfiguration.java
+++ b/vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/util/VespaConfiguration.java
@@ -113,7 +113,7 @@ public class VespaConfiguration {
}
- public int randomSartupSleepMs() {
+ public int randomStartupSleepMs() {
return getInt(RANDOM_STARTUP_SLEEP, 30000);
}
@@ -194,7 +194,7 @@ public class VespaConfiguration {
sb.append(ROUTE + ": " + route() +"\n");
sb.append(MAX_SLEEP_TIME_MS + ": " + maxSleepTimeMs() +"\n");
sb.append(MAX_IN_FLIGHT_REQUESTS + ": " + maxInFlightRequests() +"\n");
- sb.append(RANDOM_STARTUP_SLEEP + ": " + randomSartupSleepMs() +"\n");
+ sb.append(RANDOM_STARTUP_SLEEP + ": " + randomStartupSleepMs() +"\n");
sb.append(NUM_RETRIES + ": " + numRetries() +"\n");
return sb.toString();
}