github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-03 01:31:04 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-3438 Sqoop Import with create hcatalog table for ORC will not work with Hive3 as the table created would be a ACID table and transactional

Browse Source 
Adding tests

Change-Id: I03eb99c469e030deff84982c724a72f311a0f631
This commit is contained in:
Denes Bodo 2019-05-09 14:47:08 +02:00
parent 16db85f335
commit ec707d0b38
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/test/org/apache/sqoop/hcat/HCatalogImportTest.java
View File

@ -770,6 +770,29 @@ public void testTableCreation() throws Exception {
null, true, false); null, true, false);
} }
@Test
public void testExternalTableCreation() throws Exception {
final int TOTAL_RECORDS = 1 * 10;
String table = getTableName().toUpperCase();
ColumnGenerator[] cols = new ColumnGenerator[] {
HCatalogTestUtils.colGenerator(HCatalogTestUtils.forIdx(0),
"varchar(20)", Types.VARCHAR, HCatFieldSchema.Type.STRING, 0, 0,
new HiveVarchar("1", 20), "1", KeyType.STATIC_KEY),
HCatalogTestUtils.colGenerator(HCatalogTestUtils.forIdx(1),
"varchar(20)", Types.VARCHAR, HCatFieldSchema.Type.STRING, 0, 0,
new HiveVarchar("2", 20), "2", KeyType.DYNAMIC_KEY),
};
List<String> addlArgsArray = new ArrayList<String>();
addlArgsArray.add("--create-hcatalog-table");
addlArgsArray.add("--hcatalog-external-table");
addlArgsArray.add("--hcatalog-storage-stanza");
addlArgsArray.add("\"stored as orc tblproperties (\"transactional\"=\"false\")\"");
setExtraArgs(addlArgsArray);
utils.dropHCatTableIfExists(table, SqoopHCatUtilities.DEFHCATDB);
runHCatImport(addlArgsArray, TOTAL_RECORDS, table, cols,
null, true, false);
}
@Test @Test
public void testTableCreationWithPartition() throws Exception { public void testTableCreationWithPartition() throws Exception {
final int TOTAL_RECORDS = 1 * 10; final int TOTAL_RECORDS = 1 * 10;