fixed a bug

zhanif3 · Mar 30, 2012 · 5aebfdf · 5aebfdf
1 parent 73b29a7
commit 5aebfdf
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/main/java/io/covert/binary/analysis/BinaryAnalysisJob.java b/src/main/java/io/covert/binary/analysis/BinaryAnalysisJob.java
@@ -31,6 +31,7 @@ public class BinaryAnalysisJob extends Configured implements Tool  {
 
 	private static void usage(String msg)
 	{
+		System.err.println("Error: "+msg);
 		System.err.println("Usage: hadoop jar JARFILE.jar "+BinaryAnalysisJob.class.getName()+" <inDir> <outDir>");
 		System.err.println("    inDir  - HDFS input dir");
 		System.err.println("    outDir - HDFS output dir\n");

diff --git a/src/main/java/io/covert/binary/analysis/BinaryAnalysisMapper.java b/src/main/java/io/covert/binary/analysis/BinaryAnalysisMapper.java
@@ -32,6 +32,7 @@
 import org.apache.hadoop.io.BytesWritable;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.mapreduce.Mapper;
+import org.apache.log4j.Level;
 import org.apache.log4j.Logger;
 
 public class BinaryAnalysisMapper<K, V> extends Mapper<Text, BytesWritable, K, V>
@@ -66,7 +67,6 @@ public class BinaryAnalysisMapper<K, V> extends Mapper<Text, BytesWritable, K, V
 
 	protected void setup(Context context) throws java.io.IOException ,InterruptedException 
 	{
-
 		Configuration conf = context.getConfiguration();
 		try {
 			parser = (OutputParser<K, V>) Class.forName(conf.get("binary.analysis.output.parser")).newInstance();
@@ -121,7 +121,7 @@ protected void map(Text key, BytesWritable value, Context context)
 		uuid++;
 		File binaryFile = new File(dataDir, uuid+fileExtention);
 		writeToFile(value, binaryFile, context);
-		substitutionMap.put("file", binaryFile.getName());
+		substitutionMap.put("file", binaryFile.getPath());
 
 		execute(key, value, context);