sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From b...@apache.org
Subject sqoop git commit: SQOOP-3367: Improve third party tests to be able to execute them in a single JVM
Date Tue, 28 Aug 2018 13:32:54 GMT
Repository: sqoop
Updated Branches:
  refs/heads/trunk 816146df5 -> 327aec8bf


SQOOP-3367: Improve third party tests to be able to execute them in a single JVM

(Szabolcs Vasas via Boglarka Egyed)


Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/327aec8b
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/327aec8b
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/327aec8b

Branch: refs/heads/trunk
Commit: 327aec8bf1b7a40936503a9c5a94b759caf16e11
Parents: 816146d
Author: Boglarka Egyed <bogi@apache.org>
Authored: Tue Aug 28 15:31:23 2018 +0200
Committer: Boglarka Egyed <bogi@apache.org>
Committed: Tue Aug 28 15:31:23 2018 +0200

----------------------------------------------------------------------
 src/java/org/apache/sqoop/hive/HiveImport.java               | 5 ++++-
 .../org/apache/sqoop/manager/oracle/OraOopTypesTest.java     | 1 +
 .../org/apache/sqoop/manager/oracle/SystemImportTest.java    | 1 +
 src/test/org/apache/sqoop/testutil/BaseSqoopTestCase.java    | 8 ++++++++
 .../org/apache/sqoop/testutil/LobAvroImportTestCase.java     | 6 ++----
 testdata/hive/scripts/customDelimImport.q                    | 2 +-
 testdata/hive/scripts/dateImport.q                           | 2 +-
 testdata/hive/scripts/decimalMapImport.q                     | 2 +-
 testdata/hive/scripts/failingImport.q                        | 2 +-
 testdata/hive/scripts/fieldWithNewlineImport.q               | 2 +-
 testdata/hive/scripts/fieldWithNewlineReplacementImport.q    | 2 +-
 testdata/hive/scripts/incrementalHiveAppend10.q              | 2 +-
 testdata/hive/scripts/incrementalHiveAppend20.q              | 2 +-
 testdata/hive/scripts/incrementalHiveAppendEmpty.q           | 2 +-
 testdata/hive/scripts/normalImport.q                         | 2 +-
 testdata/hive/scripts/numericImport.q                        | 2 +-
 testdata/hive/scripts/partitionImport.q                      | 2 +-
 17 files changed, 28 insertions(+), 17 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/src/java/org/apache/sqoop/hive/HiveImport.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/sqoop/hive/HiveImport.java b/src/java/org/apache/sqoop/hive/HiveImport.java
index 5da00a7..4880036 100644
--- a/src/java/org/apache/sqoop/hive/HiveImport.java
+++ b/src/java/org/apache/sqoop/hive/HiveImport.java
@@ -42,6 +42,8 @@ import org.apache.sqoop.SqoopOptions;
 import org.apache.sqoop.manager.ConnManager;
 import org.apache.sqoop.util.ExitSecurityException;
 
+import static org.apache.commons.lang3.StringUtils.defaultString;
+
 /**
  * Utility to import a table into the Hive metastore. Manages the connection
  * to Hive itself as well as orchestrating the use of the other classes in this
@@ -159,7 +161,8 @@ public class HiveImport implements HiveClient {
     boolean debugMode = expectedScript != null;
     if (debugMode) {
       env.add("EXPECTED_SCRIPT=" + expectedScript);
-      env.add("TMPDIR=" + options.getTempDir());
+      String tmpDir = defaultString(options.getWarehouseDir(), "/tmp");
+      env.add("TMPDIR=" + tmpDir);
     }
 
     // generate the HQL statements to run.

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/src/test/org/apache/sqoop/manager/oracle/OraOopTypesTest.java
----------------------------------------------------------------------
diff --git a/src/test/org/apache/sqoop/manager/oracle/OraOopTypesTest.java b/src/test/org/apache/sqoop/manager/oracle/OraOopTypesTest.java
index a8072b9..1f67c46 100644
--- a/src/test/org/apache/sqoop/manager/oracle/OraOopTypesTest.java
+++ b/src/test/org/apache/sqoop/manager/oracle/OraOopTypesTest.java
@@ -31,6 +31,7 @@ public class OraOopTypesTest extends OraOopTestCase {
   public void ensureTypesAfterExportMappedAsExpected() throws Exception {
     try {
       setSqoopTargetDirectory(getSqoopTargetDirectory() + "types_test");
+      setSqoopGenClassName(OraOopTypesTest.class.getSimpleName());
       String tempTableName = "ORACLE_DATATYPES_TEMPLATE";
       String tableName = "ORACLE_DATATYPES";
       createTableFromSQL("create table " + tempTableName + " ("

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/src/test/org/apache/sqoop/manager/oracle/SystemImportTest.java
----------------------------------------------------------------------
diff --git a/src/test/org/apache/sqoop/manager/oracle/SystemImportTest.java b/src/test/org/apache/sqoop/manager/oracle/SystemImportTest.java
index e0a0462..29bca87 100644
--- a/src/test/org/apache/sqoop/manager/oracle/SystemImportTest.java
+++ b/src/test/org/apache/sqoop/manager/oracle/SystemImportTest.java
@@ -86,6 +86,7 @@ public class SystemImportTest extends OraOopTestCase {
     // Generate test data in oracle
     setSqoopTargetDirectory(getSqoopTargetDirectory()
         + OracleUtils.SYSTEMTEST_TABLE_NAME);
+    setSqoopGenClassName(SystemImportTest.class.getSimpleName());
     int numRows = OracleUtils.SYSTEMTEST_NUM_ROWS;
     Connection conn = getTestEnvConnection();
     OraOopOracleQueries.setConnectionTimeZone(conn, "GMT");

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/src/test/org/apache/sqoop/testutil/BaseSqoopTestCase.java
----------------------------------------------------------------------
diff --git a/src/test/org/apache/sqoop/testutil/BaseSqoopTestCase.java b/src/test/org/apache/sqoop/testutil/BaseSqoopTestCase.java
index 1070fb8..fe6ba83 100644
--- a/src/test/org/apache/sqoop/testutil/BaseSqoopTestCase.java
+++ b/src/test/org/apache/sqoop/testutil/BaseSqoopTestCase.java
@@ -45,6 +45,7 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.Arrays;
 import java.util.List;
+import java.util.TimeZone;
 
 import static org.apache.commons.lang3.StringUtils.wrap;
 import static org.junit.Assert.fail;
@@ -217,6 +218,7 @@ public abstract class BaseSqoopTestCase {
   public void setUp() {
     // The assumption is that correct HADOOP configuration will have it set to
     // hdfs://namenode
+    resetDefaultTimeZone();
     setOnPhysicalCluster(
         !CommonArgs.LOCAL_FS.equals(System.getProperty(
             CommonArgs.FS_DEFAULT_NAME)));
@@ -711,4 +713,10 @@ public abstract class BaseSqoopTestCase {
       throw new RuntimeException(e);
     }
   }
+
+  protected void resetDefaultTimeZone() {
+    String timeZoneId = System.getProperty("user.timezone");
+    TimeZone defaultTimeZone = TimeZone.getTimeZone(timeZoneId);
+    TimeZone.setDefault(defaultTimeZone);
+  }
 }

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/src/test/org/apache/sqoop/testutil/LobAvroImportTestCase.java
----------------------------------------------------------------------
diff --git a/src/test/org/apache/sqoop/testutil/LobAvroImportTestCase.java b/src/test/org/apache/sqoop/testutil/LobAvroImportTestCase.java
index 20d6151..4133713 100644
--- a/src/test/org/apache/sqoop/testutil/LobAvroImportTestCase.java
+++ b/src/test/org/apache/sqoop/testutil/LobAvroImportTestCase.java
@@ -212,8 +212,7 @@ public abstract class LobAvroImportTestCase extends ImportJobTestCase
{
     ByteBuffer buf = (ByteBuffer) record.get(getColName(0));
     String returnVal = new String(buf.array());
     String expectedStart = "externalLob(lf,_lob/large_obj";
-    String expectedEnd = getTableNum() + "_m_0000000.lob,68,"
-      + data.length() + ")";
+    String expectedEnd = "_m_0000000.lob,68," + data.length() + ")";
 
     assertNotNull(returnVal);
     assertTrue("ExpectedStart: " + expectedStart + ", value: " + returnVal, returnVal.startsWith(expectedStart));
@@ -303,8 +302,7 @@ public abstract class LobAvroImportTestCase extends ImportJobTestCase
{
     ByteBuffer buf = (ByteBuffer) record.get(getColName(0));
     String returnVal = new String(buf.array());
     String expectedStart = "externalLob(lf,_lob/large_obj";
-    String expectedEnd = getTableNum() + "_m_0000000.lob,68,"
-      + data.length() + ")";
+    String expectedEnd = "_m_0000000.lob,68," + data.length() + ")";
 
     assertNotNull(returnVal);
     assertTrue("ExpectedStart: " + expectedStart + ", value: " + returnVal, returnVal.startsWith(expectedStart));

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/customDelimImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/customDelimImport.q b/testdata/hive/scripts/customDelimImport.q
index a273969..5e3f0e9 100644
--- a/testdata/hive/scripts/customDelimImport.q
+++ b/testdata/hive/scripts/customDelimImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `CUSTOM_DELIM_IMPORT` ( `DATA_COL0` STRING, `DATA_COL1` INT, `DATA_COL2`
STRING) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\054' LINES TERMINATED BY '\174' STORED
AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/CUSTOM_DELIM_IMPORT' INTO TABLE `CUSTOM_DELIM_IMPORT`;
+LOAD DATA INPATH 'file:BASEPATH/CUSTOM_DELIM_IMPORT' INTO TABLE `CUSTOM_DELIM_IMPORT`;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/dateImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/dateImport.q b/testdata/hive/scripts/dateImport.q
index 476d431..7fec790 100644
--- a/testdata/hive/scripts/dateImport.q
+++ b/testdata/hive/scripts/dateImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `DATE_HIVE_IMPORT` ( `DATA_COL0` STRING, `DATA_COL1` STRING) ROW
FORMAT DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/DATE_HIVE_IMPORT' INTO TABLE `DATE_HIVE_IMPORT`;
+LOAD DATA INPATH 'file:BASEPATH/DATE_HIVE_IMPORT' INTO TABLE `DATE_HIVE_IMPORT`;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/decimalMapImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/decimalMapImport.q b/testdata/hive/scripts/decimalMapImport.q
index 8f05d58..bf91b3b 100644
--- a/testdata/hive/scripts/decimalMapImport.q
+++ b/testdata/hive/scripts/decimalMapImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `DECIMAL_MAP_HIVE_IMPORT` ( `DATA_COL0` DECIMAL(10, 10), `DATA_COL1`
STRING) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED BY '\012' STORED
AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/DECIMAL_MAP_HIVE_IMPORT' INTO TABLE `DECIMAL_MAP_HIVE_IMPORT`;
+LOAD DATA INPATH 'file:BASEPATH/DECIMAL_MAP_HIVE_IMPORT' INTO TABLE `DECIMAL_MAP_HIVE_IMPORT`;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/failingImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/failingImport.q b/testdata/hive/scripts/failingImport.q
index 476d431..7fec790 100644
--- a/testdata/hive/scripts/failingImport.q
+++ b/testdata/hive/scripts/failingImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `DATE_HIVE_IMPORT` ( `DATA_COL0` STRING, `DATA_COL1` STRING) ROW
FORMAT DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/DATE_HIVE_IMPORT' INTO TABLE `DATE_HIVE_IMPORT`;
+LOAD DATA INPATH 'file:BASEPATH/DATE_HIVE_IMPORT' INTO TABLE `DATE_HIVE_IMPORT`;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/fieldWithNewlineImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/fieldWithNewlineImport.q b/testdata/hive/scripts/fieldWithNewlineImport.q
index c6c9ebd..662525b 100644
--- a/testdata/hive/scripts/fieldWithNewlineImport.q
+++ b/testdata/hive/scripts/fieldWithNewlineImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `FIELD_WITH_NL_HIVE_IMPORT` ( `DATA_COL0` STRING, `DATA_COL1`
INT, `DATA_COL2` STRING) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED
BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/FIELD_WITH_NL_HIVE_IMPORT' INTO TABLE `FIELD_WITH_NL_HIVE_IMPORT`;
+LOAD DATA INPATH 'file:BASEPATH/FIELD_WITH_NL_HIVE_IMPORT' INTO TABLE `FIELD_WITH_NL_HIVE_IMPORT`;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/fieldWithNewlineReplacementImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/fieldWithNewlineReplacementImport.q b/testdata/hive/scripts/fieldWithNewlineReplacementImport.q
index a4b8a59..d3a1794 100644
--- a/testdata/hive/scripts/fieldWithNewlineReplacementImport.q
+++ b/testdata/hive/scripts/fieldWithNewlineReplacementImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `FIELD_WITH_NL_REPLACEMENT_HIVE_IMPORT` ( `DATA_COL0` STRING,
`DATA_COL1` INT, `DATA_COL2` STRING) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001' LINES
TERMINATED BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/FIELD_WITH_NL_REPLACEMENT_HIVE_IMPORT' INTO
TABLE `FIELD_WITH_NL_REPLACEMENT_HIVE_IMPORT`;
+LOAD DATA INPATH 'file:BASEPATH/FIELD_WITH_NL_REPLACEMENT_HIVE_IMPORT' INTO TABLE `FIELD_WITH_NL_REPLACEMENT_HIVE_IMPORT`;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/incrementalHiveAppend10.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/incrementalHiveAppend10.q b/testdata/hive/scripts/incrementalHiveAppend10.q
index 383c7b4..7a20991 100644
--- a/testdata/hive/scripts/incrementalHiveAppend10.q
+++ b/testdata/hive/scripts/incrementalHiveAppend10.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `incrementalHiveAppendEmptyThenFullhive` ( `ID` INT) ROW FORMAT
DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/incrementalHiveAppendEmptyThenFull' INTO
TABLE `incrementalHiveAppendEmptyThenFullhive`;
\ No newline at end of file
+LOAD DATA INPATH 'file:BASEPATH/incrementalHiveAppendEmptyThenFull' INTO TABLE `incrementalHiveAppendEmptyThenFullhive`;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/incrementalHiveAppend20.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/incrementalHiveAppend20.q b/testdata/hive/scripts/incrementalHiveAppend20.q
index 383c7b4..7a20991 100644
--- a/testdata/hive/scripts/incrementalHiveAppend20.q
+++ b/testdata/hive/scripts/incrementalHiveAppend20.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `incrementalHiveAppendEmptyThenFullhive` ( `ID` INT) ROW FORMAT
DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/incrementalHiveAppendEmptyThenFull' INTO
TABLE `incrementalHiveAppendEmptyThenFullhive`;
\ No newline at end of file
+LOAD DATA INPATH 'file:BASEPATH/incrementalHiveAppendEmptyThenFull' INTO TABLE `incrementalHiveAppendEmptyThenFullhive`;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/incrementalHiveAppendEmpty.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/incrementalHiveAppendEmpty.q b/testdata/hive/scripts/incrementalHiveAppendEmpty.q
index 383c7b4..7a20991 100644
--- a/testdata/hive/scripts/incrementalHiveAppendEmpty.q
+++ b/testdata/hive/scripts/incrementalHiveAppendEmpty.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `incrementalHiveAppendEmptyThenFullhive` ( `ID` INT) ROW FORMAT
DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/incrementalHiveAppendEmptyThenFull' INTO
TABLE `incrementalHiveAppendEmptyThenFullhive`;
\ No newline at end of file
+LOAD DATA INPATH 'file:BASEPATH/incrementalHiveAppendEmptyThenFull' INTO TABLE `incrementalHiveAppendEmptyThenFullhive`;
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/normalImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/normalImport.q b/testdata/hive/scripts/normalImport.q
index 34d6ac1..06645e3 100644
--- a/testdata/hive/scripts/normalImport.q
+++ b/testdata/hive/scripts/normalImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `NORMAL_HIVE_IMPORT` ( `DATA_COL0` STRING, `DATA_COL1` INT, `DATA_COL2`
STRING) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED BY '\012' STORED
AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/NORMAL_HIVE_IMPORT' INTO TABLE `NORMAL_HIVE_IMPORT`;
+LOAD DATA INPATH 'file:BASEPATH/NORMAL_HIVE_IMPORT' INTO TABLE `NORMAL_HIVE_IMPORT`;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/numericImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/numericImport.q b/testdata/hive/scripts/numericImport.q
index bef7c71..3c60b35 100644
--- a/testdata/hive/scripts/numericImport.q
+++ b/testdata/hive/scripts/numericImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `NUMERIC_HIVE_IMPORT` ( `DATA_COL0` DOUBLE, `DATA_COL1` STRING)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001' LINES TERMINATED BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/NUMERIC_HIVE_IMPORT' INTO TABLE `NUMERIC_HIVE_IMPORT`;
+LOAD DATA INPATH 'file:BASEPATH/NUMERIC_HIVE_IMPORT' INTO TABLE `NUMERIC_HIVE_IMPORT`;

http://git-wip-us.apache.org/repos/asf/sqoop/blob/327aec8b/testdata/hive/scripts/partitionImport.q
----------------------------------------------------------------------
diff --git a/testdata/hive/scripts/partitionImport.q b/testdata/hive/scripts/partitionImport.q
index 68ce7c1..59abab7 100644
--- a/testdata/hive/scripts/partitionImport.q
+++ b/testdata/hive/scripts/partitionImport.q
@@ -14,4 +14,4 @@
 -- See the License for the specific language governing permissions and
 -- limitations under the License.
 CREATE TABLE IF NOT EXISTS `PARTITION_HIVE_IMPORT` ( `DATA_COL0` STRING, `DATA_COL1` INT,
`DATA_COL2` STRING) PARTITIONED BY (ds STRING) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\001'
LINES TERMINATED BY '\012' STORED AS TEXTFILE;
-LOAD DATA INPATH 'file:BASEPATH/sqoop/warehouse/PARTITION_HIVE_IMPORT' INTO TABLE `PARTITION_HIVE_IMPORT`
PARTITION (ds='20110413');
+LOAD DATA INPATH 'file:BASEPATH/PARTITION_HIVE_IMPORT' INTO TABLE `PARTITION_HIVE_IMPORT`
PARTITION (ds='20110413');


Mime
View raw message