You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by kh...@apache.org on 2013/09/26 20:06:18 UTC

svn commit: r1526634 - /hive/trunk/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java

Author: khorgath
Date: Thu Sep 26 18:06:17 2013
New Revision: 1526634

URL: http://svn.apache.org/r1526634
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/trunk/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java

Modified: hive/trunk/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java
URL: http://svn.apache.org/viewvc/hive/trunk/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java?rev=1526634&r1=1526633&r2=1526634&view=diff
==============================================================================
--- hive/trunk/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java (original)
+++ hive/trunk/hcatalog/storage-handlers/hbase/src/test/org/apache/hcatalog/hbase/TestHCatHBaseInputFormat.java Thu Sep 26 18:06:17 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);