You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2011/11/01 16:27:49 UTC
svn commit: r1196057 -
/incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/FileCountMR.java
Author: ecn
Date: Tue Nov 1 15:27:49 2011
New Revision: 1196057
URL: http://svn.apache.org/viewvc?rev=1196057&view=rev
Log:
ACCUMULO-86: example is getting NPE
Modified:
incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/FileCountMR.java
Modified: incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/FileCountMR.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/FileCountMR.java?rev=1196057&r1=1196056&r2=1196057&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/FileCountMR.java (original)
+++ incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/FileCountMR.java Tue Nov 1 15:27:49 2011
@@ -36,6 +36,7 @@ import org.apache.hadoop.util.ToolRunner
public class FileCountMR extends Configured implements Tool {
private static final String OUTPUT_VIS = FileCountMR.class.getSimpleName() + ".output.vis";
+ private static final Text EMPTY = new Text();
public static class FileCountMapper extends Mapper<Key,Value,Key,Value> {
long dirCount = 0;
@@ -114,7 +115,7 @@ public class FileCountMR extends Configu
}
Mutation m = new Mutation(QueryUtil.getRow(key.getRow().toString()));
m.put(QueryUtil.DIR_COLF, QueryUtil.COUNTS_COLQ, colvis, sas.aggregate());
- context.write(null, m);
+ context.write(EMPTY, m);
}
@Override