diff --git a/data/scripts/q_test_cleanup_for_encryption.sql b/data/scripts/q_test_cleanup_for_encryption.sql deleted file mode 100644 index 070cdbe..0000000 --- a/data/scripts/q_test_cleanup_for_encryption.sql +++ /dev/null @@ -1 +0,0 @@ -DROP TABLE IF EXISTS src PURGE; diff --git a/data/scripts/q_test_cleanup_src.sql b/data/scripts/q_test_cleanup_src.sql new file mode 100644 index 0000000..070cdbe --- /dev/null +++ b/data/scripts/q_test_cleanup_src.sql @@ -0,0 +1 @@ +DROP TABLE IF EXISTS src PURGE; diff --git a/data/scripts/q_test_init_for_encryption.sql b/data/scripts/q_test_init_for_encryption.sql deleted file mode 100644 index 56b44e0..0000000 --- a/data/scripts/q_test_init_for_encryption.sql +++ /dev/null @@ -1,5 +0,0 @@ -DROP TABLE IF EXISTS src PURGE; - -CREATE TABLE src(key STRING COMMENT 'default', value STRING COMMENT 'default') STORED AS TEXTFILE; - -LOAD DATA LOCAL INPATH "${hiveconf:test.data.dir}/kv1.txt" OVERWRITE INTO TABLE src; diff --git a/data/scripts/q_test_init_src.sql b/data/scripts/q_test_init_src.sql new file mode 100644 index 0000000..56b44e0 --- /dev/null +++ b/data/scripts/q_test_init_src.sql @@ -0,0 +1,5 @@ +DROP TABLE IF EXISTS src PURGE; + +CREATE TABLE src(key STRING COMMENT 'default', value STRING COMMENT 'default') STORED AS TEXTFILE; + +LOAD DATA LOCAL INPATH "${hiveconf:test.data.dir}/kv1.txt" OVERWRITE INTO TABLE src; diff --git a/data/scripts/q_test_init_src_with_stats.sql b/data/scripts/q_test_init_src_with_stats.sql new file mode 100644 index 0000000..765d6c7 --- /dev/null +++ b/data/scripts/q_test_init_src_with_stats.sql @@ -0,0 +1,9 @@ +DROP TABLE IF EXISTS src PURGE; + +CREATE TABLE src(key STRING COMMENT 'default', value STRING COMMENT 'default') STORED AS TEXTFILE; + +LOAD DATA LOCAL INPATH "${hiveconf:test.data.dir}/kv1.txt" OVERWRITE INTO TABLE src; + +ANALYZE TABLE src COMPUTE STATISTICS; + +ANALYZE TABLE src COMPUTE STATISTICS FOR COLUMNS key,value; diff --git a/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/TestMTQueries.java b/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/TestMTQueries.java index 198fe48..ad2baa2 100644 --- a/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/TestMTQueries.java +++ b/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/TestMTQueries.java @@ -36,7 +36,8 @@ public void testMTQueries1() throws Exception { String[] testNames = new String[] {"join2.q", "groupby1.q", "input1.q", "input19.q"}; File[] qfiles = setupQFiles(testNames); - QTestUtil[] qts = QTestUtil.queryListRunnerSetup(qfiles, resDir, logDir); + QTestUtil[] qts = QTestUtil.queryListRunnerSetup(qfiles, resDir, logDir, "q_test_init_src_with_stats.sql", + "q_test_cleanup_src_with_stats.sql"); for (QTestUtil util : qts) { // derby fails creating multiple stats aggregator concurrently util.getConf().setBoolean("hive.exec.submitviachild", true); diff --git a/itests/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java b/itests/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java index 201c3d3..6d60d19 100644 --- a/itests/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java +++ b/itests/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java @@ -198,8 +198,8 @@ public EncryptedHDFSCliConfig() { setResultsDir("ql/src/test/results/clientpositive/encrypted"); setLogDir("itests/qtest/target/qfile-results/clientpositive"); - setInitScript("q_test_init_for_encryption.sql"); - setCleanupScript("q_test_cleanup_for_encryption.sql"); + setInitScript("q_test_init_src.sql"); + setCleanupScript("q_test_cleanup_src.sql"); setClusterType(MiniClusterType.mr); @@ -313,8 +313,8 @@ public NegativeMinimrCli() { setResultsDir("ql/src/test/results/clientnegative"); setLogDir("itests/qtest/target/qfile-results/clientnegative"); - setInitScript("q_test_init_for_encryption.sql"); - setCleanupScript("q_test_cleanup_for_encryption.sql"); + setInitScript("q_test_init_src.sql"); + setCleanupScript("q_test_cleanup_src.sql"); setHiveConfDir(""); setClusterType(MiniClusterType.mr); diff --git a/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java b/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java index e49ecd9..5f683f0 100644 --- a/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java +++ b/itests/util/src/main/java/org/apache/hadoop/hive/ql/QTestUtil.java @@ -1965,12 +1965,14 @@ public void run() { * @return one QTestUtil for each query file */ public static QTestUtil[] queryListRunnerSetup(File[] qfiles, String resDir, - String logDir) throws Exception + String logDir, String initScript, String cleanupScript) throws Exception { QTestUtil[] qt = new QTestUtil[qfiles.length]; for (int i = 0; i < qfiles.length; i++) { qt[i] = new QTestUtil(resDir, logDir, MiniClusterType.none, null, "0.20", - defaultInitScript, defaultCleanupScript, false, false); + initScript == null ? defaultInitScript : initScript, + cleanupScript == null ? defaultCleanupScript : cleanupScript, + false, false); qt[i].addFile(qfiles[i]); qt[i].clearTestSideEffects(); }