diff --git a/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/TestMultiOutputFormat.java b/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/TestMultiOutputFormat.java index d4271e5..4643be3 100644 --- a/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/TestMultiOutputFormat.java +++ b/hcatalog/core/src/test/java/org/apache/hive/hcatalog/mapreduce/TestMultiOutputFormat.java @@ -139,13 +139,19 @@ public void testMultiOutputFormatWithoutReduce() throws Throwable { // Verify if the configs are merged Path[] fileClassPaths = DistributedCache.getFileClassPaths(job.getConfiguration()); List fileClassPathsList = Arrays.asList(fileClassPaths); - Assert.assertTrue(fileClassPathsList.contains(new Path(inputFile))); - Assert.assertTrue(fileClassPathsList.contains(new Path(dummyFile))); + Assert.assertTrue("Cannot find " + (new Path(inputFile)) + " in " + fileClassPathsList, + fileClassPathsList.contains(new Path(inputFile))); + Assert.assertTrue("Cannot find " + (new Path(dummyFile)) + " in " + fileClassPathsList, + fileClassPathsList.contains(new Path(dummyFile))); URI[] cacheFiles = DistributedCache.getCacheFiles(job.getConfiguration()); List cacheFilesList = Arrays.asList(cacheFiles); - Assert.assertTrue(cacheFilesList.contains(new Path(inputFile).makeQualified(fs).toUri())); - Assert.assertTrue(cacheFilesList.contains(new Path(dummyFile).makeQualified(fs).toUri())); + URI inputFileURI = new Path(inputFile).makeQualified(fs).toUri(); + Assert.assertTrue("Cannot find " + inputFileURI + " in " + cacheFilesList, + cacheFilesList.contains(inputFileURI)); + URI dummyFileURI = new Path(dummyFile).makeQualified(fs).toUri(); + Assert.assertTrue("Cannot find " + dummyFileURI + " in " + cacheFilesList, + cacheFilesList.contains(dummyFileURI)); Assert.assertTrue(job.waitForCompletion(true));