Author: thejas
Date: Thu Sep 26 22:25:18 2013
New Revision: 1526726
URL: http://svn.apache.org/r1526726
Log:
HIVE-5362 : TestHCatHBaseInputFormat has a bug which will not allow it to run
on JDK7 and RHEL 6 (Viraj Bhat via Sushanth Sowmyan)
Modified:
hive/branches/branch-0.12/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java
Modified:
hive/branches/branch-0.12/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java
URL:
http://svn.apache.org/viewvc/hive/branches/branch-0.12/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java?rev=1526726&r1=1526725&r2=1526726&view=diff
==============================================================================
---
hive/branches/branch-0.12/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java
(original)
+++
hive/branches/branch-0.12/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java
Thu Sep 26 22:25:18 2013
@@ -229,7 +229,7 @@ public class TestHCatHBaseInputFormat ex
// Note: These asserts only works in case of LocalJobRunner as they run in
same jvm.
// If using MiniMRCluster, the tests will have to be modified.
assertFalse(MapReadHTable.error);
- assertEquals(MapReadHTable.count, 1);
+ assertEquals(1, MapReadHTable.count);
String dropTableQuery = "DROP TABLE " + hbaseTableName;
CommandProcessorResponse responseThree = hcatDriver.run(dropTableQuery);
@@ -291,7 +291,7 @@ public class TestHCatHBaseInputFormat ex
job.setNumReduceTasks(0);
assertTrue(job.waitForCompletion(true));
assertFalse(MapReadProjHTable.error);
- assertEquals(MapReadProjHTable.count, 1);
+ assertEquals(1, MapReadProjHTable.count);
String dropTableQuery = "DROP TABLE " + tableName;
CommandProcessorResponse responseThree = hcatDriver.run(dropTableQuery);
@@ -325,7 +325,7 @@ public class TestHCatHBaseInputFormat ex
HCatUtil.serialize(getHiveConf().getAllProperties()));
// output settings
- Path outputDir = new Path(getTestDir(),
"mapred/testHBaseTableProjectionReadMR");
+ Path outputDir = new Path(getTestDir(),
"mapred/testHBaseInputFormatProjectionReadMR");
FileSystem fs = getFileSystem();
if (fs.exists(outputDir)) {
fs.delete(outputDir, true);
@@ -361,8 +361,8 @@ public class TestHCatHBaseInputFormat ex
RunningJob runJob = JobClient.runJob(job);
runJob.waitForCompletion();
assertTrue(runJob.isSuccessful());
- assertFalse(MapReadProjHTable.error);
- assertEquals(MapReadProjHTable.count, 1);
+ assertFalse(MapReadProjectionHTable.error);
+ assertEquals(1, MapReadProjectionHTable.count);
String dropTableQuery = "DROP TABLE " + tableName;
CommandProcessorResponse responseThree = hcatDriver.run(dropTableQuery);