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 <afu...@apache.org> Authored: Mon Feb 6 22:35:47 2012 +0000 Committer: Adam Fuchs <afu...@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
