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)) {