Adding a more text to options.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/7684ef96 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/7684ef96 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/7684ef96 Branch: refs/heads/master Commit: 7684ef969ac854530e4888b88ff08820e58b0da5 Parents: e110cd7 Author: Aaron McCurry <[email protected]> Authored: Fri Aug 9 08:58:27 2013 -0400 Committer: Aaron McCurry <[email protected]> Committed: Fri Aug 9 08:58:27 2013 -0400 ---------------------------------------------------------------------- .../blur/mapreduce/lib/BlurOutputFormatTest.java | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7684ef96/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/BlurOutputFormatTest.java ---------------------------------------------------------------------- diff --git a/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/BlurOutputFormatTest.java b/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/BlurOutputFormatTest.java index 96d55ab..67135cb 100644 --- a/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/BlurOutputFormatTest.java +++ b/blur-mapred/src/test/java/org/apache/blur/mapreduce/lib/BlurOutputFormatTest.java @@ -358,10 +358,24 @@ public class BlurOutputFormatTest { Path path = new Path(tableUri, BlurUtil.getShardName(i)); FileSystem fileSystem = path.getFileSystem(job.getConfiguration()); FileStatus[] listStatus = fileSystem.listStatus(path); - assertEquals(0, listStatus.length); + assertEquals(toString(listStatus), 0, listStatus.length); } } + private String toString(FileStatus[] listStatus) { + if (listStatus == null || listStatus.length == 0) { + return ""; + } + String s = ""; + for (FileStatus fileStatus : listStatus) { + if (s.length() > 0) { + s += ","; + } + s += fileStatus.getPath(); + } + return s; + } + public static String readFile(String name) throws IOException { DataInputStream f = localFs.open(new Path(TEST_ROOT_DIR + "/" + name)); BufferedReader b = new BufferedReader(new InputStreamReader(f));
