diff options
author | Kristian Aune <kraune@oath.com> | 2017-11-17 09:54:39 +0100 |
---|---|---|
committer | Kristian Aune <kraune@oath.com> | 2017-11-17 09:54:39 +0100 |
commit | f3b0da051259f1d343402f6c3f14cc6644dd0e98 (patch) | |
tree | c4ee6c0ed0d512b56ea5f8b46a23344daaaf8bf8 /vespa-hadoop/src | |
parent | 82a979fbd3eb53bece2ffa27a05e762e03154d73 (diff) |
rename method, optimize import
Diffstat (limited to 'vespa-hadoop/src')
-rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/VespaRecordWriter.java | 5 | ||||
-rw-r--r-- | vespa-hadoop/src/main/java/com/yahoo/vespa/hadoop/mapreduce/util/VespaConfiguration.java | 4 |
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 <key, value> 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(); } |