SQOOP-931: Integrate HCatalog with Sqoop
[sqoop.git] / src / test / com / cloudera / sqoop / hive / TestHiveImport.java
index 52e598f..9c47bad 100644 (file)
@@ -51,6 +51,16 @@ public class TestHiveImport extends ImportJobTestCase {
   public static final Log LOG = LogFactory.getLog(
       TestHiveImport.class.getName());
 
+  public void setUp() {
+    super.setUp();
+    HiveImport.setTestMode(true);
+  }
+
+  public void tearDown() {
+    super.tearDown();
+    HiveImport.setTestMode(false);
+  }
+
   /**
    * Sets the expected number of columns in the table being manipulated
    * by the test. Under the hood, this sets the expected column names
@@ -188,9 +198,10 @@ public class TestHiveImport extends ImportJobTestCase {
     SqoopOptions options = getSqoopOptions(args, tool);
     String hiveHome = options.getHiveHome();
     assertNotNull("hive.home was not set", hiveHome);
-    Path testDataPath = new Path(new Path(hiveHome),
-        "scripts/" + verificationScript);
-    System.setProperty("expected.script", testDataPath.toString());
+    String testDataPath = new Path(new Path(hiveHome),
+        "scripts/" + verificationScript).toString();
+    System.setProperty("expected.script",
+        new File(testDataPath).getAbsolutePath());
 
     // verify that we can import it correctly into hive.
     runImport(tool, args);
@@ -373,9 +384,8 @@ public class TestHiveImport extends ImportJobTestCase {
     BufferedReader br = new BufferedReader(fr);
     try {
       // verify the output
-      assertEquals("test with  new lines " + '\01' + "42" + '\01'
-          + "oh no  field delims                                           ",
-          br.readLine());
+      assertEquals(br.readLine(), "test with  new lines " + '\01' + "42"
+          + '\01' + "oh no  field delims ");
       assertEquals(br.readLine(), null); // should only be one line
     } catch (IOException ioe) {
       fail("Unable to read files generated from hive");
@@ -424,9 +434,8 @@ public class TestHiveImport extends ImportJobTestCase {
     BufferedReader br = new BufferedReader(fr);
     try {
       // verify the output
-      assertEquals("test with new lines " + '\01' + "42" + '\01'
-          + "oh no   field delims                                            ",
-          br.readLine());
+      assertEquals(br.readLine(), "test with new lines " + '\01' + "42"
+          + '\01' + "oh no   field delims  ");
       assertEquals(br.readLine(), null); // should only be one line
     } catch (IOException ioe) {
       fail("Unable to read files generated from hive");