mirror of
https://github.com/apache/impala.git
synced 2026-01-10 09:00:16 -05:00
Put transactional tables into 'managed' directory
HIVE-22794 disallows ACID tables outside of the 'managed' warehouse directory. This change updates data loading to make it conform to the new rules. The following tests had to be modified to use the new paths: * AnalyzeDDLTest.TestCreateTableLikeFileOrc() * create-table-like-file-orc.test Change-Id: Id3b65f56bf7f225b1d29aa397f987fdd7eb7176c Reviewed-on: http://gerrit.cloudera.org:8080/15708 Reviewed-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com> Tested-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com>
This commit is contained in:
committed by
Impala Public Jenkins
parent
c52b1d8a68
commit
b770d2d378
@@ -332,6 +332,8 @@ LOCATION '{hdfs_location}';
|
||||
ALTER TABLE {table_name}_tmp ADD IF NOT EXISTS PARTITION (year=2009, month=1);
|
||||
ALTER TABLE {table_name}_tmp ADD IF NOT EXISTS PARTITION (year=2009, month=2);
|
||||
ALTER TABLE {table_name}_tmp ADD IF NOT EXISTS PARTITION (year=2009, month=3);
|
||||
---- TABLE_PROPERTIES
|
||||
transactional=false
|
||||
---- DEPENDENT_LOAD
|
||||
USE {db_name}{db_suffix};
|
||||
-- Step 4: Stream the data from tmp text table to desired format tmp table
|
||||
@@ -458,6 +460,8 @@ USE {db_name}{db_suffix};
|
||||
ALTER TABLE {table_name}_tmp ADD IF NOT EXISTS PARTITION (year=2009, month=1);
|
||||
ALTER TABLE {table_name}_tmp ADD IF NOT EXISTS PARTITION (year=2009, month=2);
|
||||
ALTER TABLE {table_name}_tmp ADD IF NOT EXISTS PARTITION (year=2009, month=3);
|
||||
---- TABLE_PROPERTIES
|
||||
transactional=false
|
||||
---- DEPENDENT_LOAD
|
||||
USE {db_name}{db_suffix};
|
||||
-- Step 4: Stream the data from tmp text table to desired format tmp table
|
||||
@@ -1526,6 +1530,8 @@ CREATE EXTERNAL TABLE IF NOT EXISTS {db_name}{db_suffix}.{table_name} (
|
||||
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
|
||||
STORED AS {file_format}
|
||||
LOCATION '{hdfs_location}';
|
||||
---- TABLE_PROPERTIES
|
||||
transactional=false
|
||||
---- DEPENDENT_LOAD
|
||||
INSERT OVERWRITE TABLE {db_name}{db_suffix}.{table_name} SELECT * FROM {db_name}.{table_name};
|
||||
---- LOAD
|
||||
|
||||
Reference in New Issue
Block a user