accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ujustgotbi...@apache.org
Subject [04/50] git commit: ACCUMULO-375 fixed input split problem
Date Thu, 06 Feb 2014 05:39:43 GMT
ACCUMULO-375 fixed input split problem

git-svn-id: https://svn.apache.org/repos/asf/incubator/accumulo/branches/1.4@1241226 13f79535-47bb-0310-9956-ffa450edef68


Project: http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/commit/a7eaf7d0
Tree: http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/tree/a7eaf7d0
Diff: http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/diff/a7eaf7d0

Branch: refs/heads/1.4.5-SNAPSHOT
Commit: a7eaf7d09b78e960eace96993485753cebad65bb
Parents: ddab37e
Author: Adam Fuchs <afuchs@apache.org>
Authored: Mon Feb 6 22:35:47 2012 +0000
Committer: Adam Fuchs <afuchs@apache.org>
Committed: Mon Feb 6 22:35:47 2012 +0000

----------------------------------------------------------------------
 .../examples/wikisearch/ingest/WikipediaInputFormat.java         | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo-wikisearch/blob/a7eaf7d0/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
----------------------------------------------------------------------
diff --git a/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
b/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
index 4c6a3b8..e8b8b52 100644
--- a/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
+++ b/ingest/src/main/java/org/apache/accumulo/examples/wikisearch/ingest/WikipediaInputFormat.java
@@ -101,7 +101,7 @@ public class WikipediaInputFormat extends TextInputFormat {
   @Override
   public List<InputSplit> getSplits(JobContext job) throws IOException {
     List<InputSplit> superSplits = super.getSplits(job);
-    List<WikipediaInputSplit> splits = new ArrayList<WikipediaInputSplit>();
+    List<InputSplit> splits = new ArrayList<InputSplit>();
     
     int numGroups = WikipediaConfiguration.getNumGroups(job.getConfiguration());
 
@@ -113,7 +113,7 @@ public class WikipediaInputFormat extends TextInputFormat {
         splits.add(new WikipediaInputSplit(fileSplit,group));
       }
     }
-    return super.getSplits(job);
+    return splits;
   }
 
   @Override


Mime
View raw message