From a2aabb3c050d54f564177fc6c3eb5ab0bbdaf4d9 Mon Sep 17 00:00:00 2001 From: Chao Sun Date: Tue, 28 Aug 2018 16:42:29 -0700 Subject: [PATCH] (Closes #60) Fix start-workload.sh This fixes two issues encountered when running start-workload.sh: 1. The README description is incorrect. It should use `=` for config key & value for auditreplay configs. 2. The mapper_class_name value doesn't work - it should look under com.linkedin.dynamometer.workloadgenerator.audit instead of com.linkedin.dynamometer.workloadgenerator --- README.md | 4 ++-- .../dynamometer/workloadgenerator/WorkloadDriver.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index c7d5b982ac..5def61f47a 100644 --- a/README.md +++ b/README.md @@ -173,8 +173,8 @@ via logging when the Dyno-NN has exited safemode and is ready for use. At this point, a workload job (map-only MapReduce job) can be launched, e.g.: ``` ./bin/start-workload.sh - -Dauditreplay.input-path hdfs:///dyno/audit_logs/ - -Dauditreplay.num-threads 50 + -Dauditreplay.input-path=hdfs:///dyno/audit_logs/ + -Dauditreplay.num-threads=50 -nn_uri hdfs://namenode_address:port/ -start_time_offset 5m -mapper_class_name AuditReplayMapper diff --git a/dynamometer-workload/src/main/java/com/linkedin/dynamometer/workloadgenerator/WorkloadDriver.java b/dynamometer-workload/src/main/java/com/linkedin/dynamometer/workloadgenerator/WorkloadDriver.java index 38f237f572..039d2cea50 100644 --- a/dynamometer-workload/src/main/java/com/linkedin/dynamometer/workloadgenerator/WorkloadDriver.java +++ b/dynamometer-workload/src/main/java/com/linkedin/dynamometer/workloadgenerator/WorkloadDriver.java @@ -141,7 +141,7 @@ public static void main(String[] args) throws Exception { private Class getMapperClass(String className) throws ClassNotFoundException { if (!className.contains(".")) { - className = WorkloadDriver.class.getPackage().getName() + "." + className; + className = WorkloadDriver.class.getPackage().getName() + ".audit." + className; } Class mapperClass = getConf().getClassByName(className); if (!WorkloadMapper.class.isAssignableFrom(mapperClass)) {