http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_schema_evolution.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_schema_evolution.q 
b/ql/src/test/queries/clientpositive/parquet_schema_evolution.q
index e767b81..00cad9e 100644
--- a/ql/src/test/queries/clientpositive/parquet_schema_evolution.q
+++ b/ql/src/test/queries/clientpositive/parquet_schema_evolution.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 set hive.mapred.mode=nonstrict;
 -- Some tables might have extra columns and struct elements on the schema than 
the on Parquet schema;
 -- This is called 'schema evolution' as the Parquet file is not ready yet for 
such new columns;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_serde.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_serde.q 
b/ql/src/test/queries/clientpositive/parquet_serde.q
index 275f92a..9661f5b 100644
--- a/ql/src/test/queries/clientpositive/parquet_serde.q
+++ b/ql/src/test/queries/clientpositive/parquet_serde.q
@@ -1,3 +1,4 @@
+--! qt:dataset:part
 set hive.mapred.mode=nonstrict;
 DROP TABLE if exists parquet_mixed_fileformat;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_0.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_0.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_0.q
index 69628b8..fa8ec86 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_0.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_0.q
@@ -1,3 +1,6 @@
+--! qt:dataset:srcbucket
+--! qt:dataset:src
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_1.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_1.q
index 95b2c9e..311334d 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_1.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;
 set hive.vectorized.execution.reduce.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_10.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_10.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_10.q
index 14077e3..c560515 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_10.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_10.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_11.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_11.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_11.q
index 48ddecf..a6e6810 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_11.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_11.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_12.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_12.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_12.q
index e3606e6..ff6949a 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_12.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_12.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_13.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_13.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_13.q
index 0763330..e5f48c8 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_13.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_13.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_14.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_14.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_14.q
index ac8eecc..3ec437f 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_14.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_14.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_15.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_15.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_15.q
index 4024b32..6906523 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_15.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_15.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_16.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_16.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_16.q
index c773e9e..49d7b5a 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_16.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_16.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_17.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_17.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_17.q
index 7a216b7..dafe677 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_17.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_17.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_2.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_2.q
index 193523e..a2c87f7 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_2.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_3.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_3.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_3.q
index a58e60a..7b08952 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_3.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_3.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_4.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_4.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_4.q
index 78e5ada..d2bd832 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_4.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_4.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_5.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_5.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_5.q
index d5758e7..071048c 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_5.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_5.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_6.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_6.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_6.q
index 50f987e..7a7a18b 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_6.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_6.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_7.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_7.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_7.q
index 1888535..d0a73a3 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_7.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_7.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_8.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_8.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_8.q
index 7d3223e..4d97cad 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_8.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_8.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_9.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_9.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_9.q
index c773e9e..49d7b5a 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_9.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_9.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_decimal_date.q
----------------------------------------------------------------------
diff --git 
a/ql/src/test/queries/clientpositive/parquet_vectorization_decimal_date.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_decimal_date.q
index fac6ad9..b7c88a0 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_decimal_date.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_decimal_date.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.explain.user=false;
 set hive.fetch.task.conversion=none;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_div0.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_div0.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_div0.q
index e8a4aa7..feeed57 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_div0.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_div0.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled = true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_limit.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_limit.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_limit.q
index 76d1bd5..399c67e 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_limit.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_limit.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_nested_udf.q
----------------------------------------------------------------------
diff --git 
a/ql/src/test/queries/clientpositive/parquet_vectorization_nested_udf.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_nested_udf.q
index 2f65b40..c488f89 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_nested_udf.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_nested_udf.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_not.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_not.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_not.q
index 343b857..70ee843 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_not.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_not.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_offset_limit.q
----------------------------------------------------------------------
diff --git 
a/ql/src/test/queries/clientpositive/parquet_vectorization_offset_limit.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_offset_limit.q
index 99e6139..e89966b 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_offset_limit.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_offset_limit.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;
 set hive.mapred.mode=nonstrict;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_part.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/parquet_vectorization_part.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_part.q
index 49eecf1..66fe981 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_part.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_part.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_part_project.q
----------------------------------------------------------------------
diff --git 
a/ql/src/test/queries/clientpositive/parquet_vectorization_part_project.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_part_project.q
index 0eb8965..d5b2e3c 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_part_project.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_part_project.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_part_varchar.q
----------------------------------------------------------------------
diff --git 
a/ql/src/test/queries/clientpositive/parquet_vectorization_part_varchar.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_part_varchar.q
index b231b37..e266d58 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_part_varchar.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_part_varchar.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 SET hive.vectorized.execution.enabled=true;
 set hive.fetch.task.conversion=none;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_vectorization_pushdown.q
----------------------------------------------------------------------
diff --git 
a/ql/src/test/queries/clientpositive/parquet_vectorization_pushdown.q 
b/ql/src/test/queries/clientpositive/parquet_vectorization_pushdown.q
index b83b556..2c52beb 100644
--- a/ql/src/test/queries/clientpositive/parquet_vectorization_pushdown.q
+++ b/ql/src/test/queries/clientpositive/parquet_vectorization_pushdown.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesparquet
 set hive.mapred.mode=nonstrict;
 set hive.explain.user=false;
 SET hive.vectorized.execution.enabled=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/parquet_write_correct_definition_levels.q
----------------------------------------------------------------------
diff --git 
a/ql/src/test/queries/clientpositive/parquet_write_correct_definition_levels.q 
b/ql/src/test/queries/clientpositive/parquet_write_correct_definition_levels.q
index 172fda6..8992ccd 100644
--- 
a/ql/src/test/queries/clientpositive/parquet_write_correct_definition_levels.q
+++ 
b/ql/src/test/queries/clientpositive/parquet_write_correct_definition_levels.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 CREATE TABLE text_tbl (a STRUCT<b:STRUCT<c:INT>>)
 STORED AS TEXTFILE;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partcols1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partcols1.q 
b/ql/src/test/queries/clientpositive/partcols1.q
index 03a5760..7f47005 100644
--- a/ql/src/test/queries/clientpositive/partcols1.q
+++ b/ql/src/test/queries/clientpositive/partcols1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 
 create table test1(col1 string) partitioned by (partitionId int);
 insert overwrite table test1 partition (partitionId=1)

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partialdhj.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partialdhj.q 
b/ql/src/test/queries/clientpositive/partialdhj.q
index c4fe1f7..ef60d4b 100644
--- a/ql/src/test/queries/clientpositive/partialdhj.q
+++ b/ql/src/test/queries/clientpositive/partialdhj.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.auto.convert.join=true;
 set hive.strict.checks.cartesian.product=false;
 set hive.merge.nway.joins=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_boolexpr.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_boolexpr.q 
b/ql/src/test/queries/clientpositive/partition_boolexpr.q
index 6178aab..cae3b76 100644
--- a/ql/src/test/queries/clientpositive/partition_boolexpr.q
+++ b/ql/src/test/queries/clientpositive/partition_boolexpr.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 set hive.mapred.mode=nonstrict;
 -- create testing table.
 create table part_boolexpr(key int, value string) partitioned by (dt int, ts 
string);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_char.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_char.q 
b/ql/src/test/queries/clientpositive/partition_char.q
index ca4447b..4d97b64 100644
--- a/ql/src/test/queries/clientpositive/partition_char.q
+++ b/ql/src/test/queries/clientpositive/partition_char.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table partition_char_1;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_coltype_literals.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_coltype_literals.q 
b/ql/src/test/queries/clientpositive/partition_coltype_literals.q
index 8da4876..e65371e 100644
--- a/ql/src/test/queries/clientpositive/partition_coltype_literals.q
+++ b/ql/src/test/queries/clientpositive/partition_coltype_literals.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.stats.column.autogather=false;
 set hive.compute.query.using.stats=false;
 drop table if exists partcoltypenum;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_condition_remover.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_condition_remover.q 
b/ql/src/test/queries/clientpositive/partition_condition_remover.q
index 39e58b8..f417eb7 100644
--- a/ql/src/test/queries/clientpositive/partition_condition_remover.q
+++ b/ql/src/test/queries/clientpositive/partition_condition_remover.q
@@ -1,3 +1,4 @@
+--! qt:dataset:alltypesorc
 
 drop table foo;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_date.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_date.q 
b/ql/src/test/queries/clientpositive/partition_date.q
index ffac790..3d131d8 100644
--- a/ql/src/test/queries/clientpositive/partition_date.q
+++ b/ql/src/test/queries/clientpositive/partition_date.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table partition_date_1;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_date2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_date2.q 
b/ql/src/test/queries/clientpositive/partition_date2.q
index cb8e5db..ae430e6 100644
--- a/ql/src/test/queries/clientpositive/partition_date2.q
+++ b/ql/src/test/queries/clientpositive/partition_date2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.metadataonly=true;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_decode_name.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_decode_name.q 
b/ql/src/test/queries/clientpositive/partition_decode_name.q
index a8381a4..7d851d9 100644
--- a/ql/src/test/queries/clientpositive/partition_decode_name.q
+++ b/ql/src/test/queries/clientpositive/partition_decode_name.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 create table sc as select * 
 from (select '2011-01-11', '2011-01-11+14:18:26' from src tablesample (1 rows)
       union all 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_multilevels.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_multilevels.q 
b/ql/src/test/queries/clientpositive/partition_multilevels.q
index 5acc5bc..5009769 100644
--- a/ql/src/test/queries/clientpositive/partition_multilevels.q
+++ b/ql/src/test/queries/clientpositive/partition_multilevels.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 set hive.mapred.mode=nonstrict;
 create table partition_test_multilevel (key string, value string) partitioned 
by (level1 string, level2 string, level3 string);
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_schema1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_schema1.q 
b/ql/src/test/queries/clientpositive/partition_schema1.q
index 550ea47..b8482be 100644
--- a/ql/src/test/queries/clientpositive/partition_schema1.q
+++ b/ql/src/test/queries/clientpositive/partition_schema1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 
 create table partition_schema1(key string, value string) partitioned by (dt 
string);
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_serde_format.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_serde_format.q 
b/ql/src/test/queries/clientpositive/partition_serde_format.q
index 9f7620c..c583454 100644
--- a/ql/src/test/queries/clientpositive/partition_serde_format.q
+++ b/ql/src/test/queries/clientpositive/partition_serde_format.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 create table src_part_serde (key int, value string) partitioned by (ds string) 
stored as sequencefile;
 insert overwrite table src_part_serde partition (ds='2011') select * from src;
 alter table src_part_serde set serde 
'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe' with SERDEPROPERTIES 
('serialization.format'='\t');

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_shared_scan.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_shared_scan.q 
b/ql/src/test/queries/clientpositive/partition_shared_scan.q
index 7ddf294..ccb8e74 100644
--- a/ql/src/test/queries/clientpositive/partition_shared_scan.q
+++ b/ql/src/test/queries/clientpositive/partition_shared_scan.q
@@ -1,3 +1,5 @@
+--! qt:dataset:part
+--! qt:dataset:alltypesorc
 set hive.merge.nway.joins=false;
 
 drop table foo;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_special_char.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_special_char.q 
b/ql/src/test/queries/clientpositive/partition_special_char.q
index b0b1ff4..319671a 100644
--- a/ql/src/test/queries/clientpositive/partition_special_char.q
+++ b/ql/src/test/queries/clientpositive/partition_special_char.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 create table sc as select * 
 from (select '2011-01-11', '2011-01-11+14:18:26' from src tablesample (1 rows)
       union all 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_timestamp.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_timestamp.q 
b/ql/src/test/queries/clientpositive/partition_timestamp.q
index 45bbba1..17c164a 100644
--- a/ql/src/test/queries/clientpositive/partition_timestamp.q
+++ b/ql/src/test/queries/clientpositive/partition_timestamp.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table partition_timestamp_1;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_timestamp2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_timestamp2.q 
b/ql/src/test/queries/clientpositive/partition_timestamp2.q
index ba4ec17..4cf3632 100644
--- a/ql/src/test/queries/clientpositive/partition_timestamp2.q
+++ b/ql/src/test/queries/clientpositive/partition_timestamp2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.metadataonly=true;
 drop table partition_timestamp2_1;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_type_check.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_type_check.q 
b/ql/src/test/queries/clientpositive/partition_type_check.q
index c459eec..081d0a3 100644
--- a/ql/src/test/queries/clientpositive/partition_type_check.q
+++ b/ql/src/test/queries/clientpositive/partition_type_check.q
@@ -1,3 +1,4 @@
+--! qt:dataset:part
 set hive.mapred.mode=nonstrict;
 set hive.typecheck.on.insert = true;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_type_in_plan.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_type_in_plan.q 
b/ql/src/test/queries/clientpositive/partition_type_in_plan.q
index 693dd24..a92b68a 100644
--- a/ql/src/test/queries/clientpositive/partition_type_in_plan.q
+++ b/ql/src/test/queries/clientpositive/partition_type_in_plan.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 -- Test partition column type is considered as the type given in table def
 -- and not as 'string'
 CREATE TABLE datePartTbl(col1 string) PARTITIONED BY (date_prt date);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_varchar1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_varchar1.q 
b/ql/src/test/queries/clientpositive/partition_varchar1.q
index dd991fd..216bcf5 100644
--- a/ql/src/test/queries/clientpositive/partition_varchar1.q
+++ b/ql/src/test/queries/clientpositive/partition_varchar1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table partition_varchar_1;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_varchar2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_varchar2.q 
b/ql/src/test/queries/clientpositive/partition_varchar2.q
index 92cb742..0053903 100644
--- a/ql/src/test/queries/clientpositive/partition_varchar2.q
+++ b/ql/src/test/queries/clientpositive/partition_varchar2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 drop table partition_varchar_2;
 
 create table partition_varchar_2 (key string, value varchar(20)) partitioned 
by (dt varchar(15), region int);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_vs_table_metadata.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_vs_table_metadata.q 
b/ql/src/test/queries/clientpositive/partition_vs_table_metadata.q
index dbb6393..eca49e2 100644
--- a/ql/src/test/queries/clientpositive/partition_vs_table_metadata.q
+++ b/ql/src/test/queries/clientpositive/partition_vs_table_metadata.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat.q
index 7b2f48d..3b547c3 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 set hive.mapred.mode=nonstrict;
 
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat10.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat10.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat10.q
index f15f72c..bc57a96 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat10.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat10.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 -- This tests that the schema can be changed for binary serde data

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat11.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat11.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat11.q
index b2db2f1..2ff680e 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat11.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat11.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 -- This tests that the schema can be changed for binary serde data

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat12.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat12.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat12.q
index 632d022..0eb6d18 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat12.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat12.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 -- This tests that the schema can be changed for binary serde data

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat13.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat13.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat13.q
index 645d53a..f495d72 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat13.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat13.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat14.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat14.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat14.q
index dba4f30..c27e45b 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat14.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat14.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.exec.reducers.max = 1;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat15.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat15.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat15.q
index 70a454f..ad2f068 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat15.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat15.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 -- This tests that the schema can be changed for binary serde data

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat16.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat16.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat16.q
index 92757f6..a97619f 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat16.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat16.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 -- This tests that the schema can be changed for binary serde data

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat2.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat2.q
index b8dddc9..62e8a1c 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat2.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 set hive.mapred.mode=nonstrict;
 -- SORT_BEFORE_DIFF
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat3.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat3.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat3.q
index b85fec5..f9f9711 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat3.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat3.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 
 
 create table partition_test_partitioned(key string, value string) partitioned 
by (dt string);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat4.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat4.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat4.q
index 33decec..14ed946 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat4.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat4.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 create table partition_test_partitioned(key string, value string) partitioned 
by (dt string);
 alter table partition_test_partitioned set fileformat sequencefile;
 insert overwrite table partition_test_partitioned partition(dt='1') select * 
from src1;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat5.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat5.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat5.q
index fc3bb84..f41c88e 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat5.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat5.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 create table partition_test_partitioned(key string, value string) partitioned 
by (dt string);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat6.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat6.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat6.q
index dac5ef2..73f2266 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat6.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat6.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 create table partition_test_partitioned(key string, value string) partitioned 
by (dt string);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat7.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat7.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat7.q
index c4a19ad..e695df7 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat7.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat7.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 create table partition_test_partitioned(key string, value string) partitioned 
by (dt string);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat8.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat8.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat8.q
index 46ea10f..30eea0a 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat8.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat8.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 -- This tests that a query can span multiple partitions which can not only 
have different file formats, but

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/partition_wise_fileformat9.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/partition_wise_fileformat9.q 
b/ql/src/test/queries/clientpositive/partition_wise_fileformat9.q
index 5205585..05fc20f 100644
--- a/ql/src/test/queries/clientpositive/partition_wise_fileformat9.q
+++ b/ql/src/test/queries/clientpositive/partition_wise_fileformat9.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.input.format = org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;
 
 -- This tests that a query can span multiple partitions which can not only 
have different file formats, but

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/pcr.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/pcr.q 
b/ql/src/test/queries/clientpositive/pcr.q
index bfa29a5..70ea05b 100644
--- a/ql/src/test/queries/clientpositive/pcr.q
+++ b/ql/src/test/queries/clientpositive/pcr.q
@@ -1,3 +1,5 @@
+--! qt:dataset:srcpart
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table pcr_t1;
 drop table pcr_t2;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/pcs.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/pcs.q 
b/ql/src/test/queries/clientpositive/pcs.q
index eb16647..2e7eff4 100644
--- a/ql/src/test/queries/clientpositive/pcs.q
+++ b/ql/src/test/queries/clientpositive/pcs.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table pcs_t1; 
 drop table pcs_t2; 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/plan_json.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/plan_json.q 
b/ql/src/test/queries/clientpositive/plan_json.q
index 503b55d..8243743 100644
--- a/ql/src/test/queries/clientpositive/plan_json.q
+++ b/ql/src/test/queries/clientpositive/plan_json.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 -- explain plan json:  the query gets the formatted json output of the query 
plan of the hive query
 
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/pointlookup.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/pointlookup.q 
b/ql/src/test/queries/clientpositive/pointlookup.q
index 951f77e..1b65cec 100644
--- a/ql/src/test/queries/clientpositive/pointlookup.q
+++ b/ql/src/test/queries/clientpositive/pointlookup.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 explain
 SELECT key
 FROM src

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/pointlookup2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/pointlookup2.q 
b/ql/src/test/queries/clientpositive/pointlookup2.q
index 6e1cb07..8ec07a0 100644
--- a/ql/src/test/queries/clientpositive/pointlookup2.q
+++ b/ql/src/test/queries/clientpositive/pointlookup2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table pcr_t1;
 drop table pcr_t2;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/pointlookup3.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/pointlookup3.q 
b/ql/src/test/queries/clientpositive/pointlookup3.q
index bb934d0..facfec0 100644
--- a/ql/src/test/queries/clientpositive/pointlookup3.q
+++ b/ql/src/test/queries/clientpositive/pointlookup3.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table pcr_t1;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/pointlookup4.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/pointlookup4.q 
b/ql/src/test/queries/clientpositive/pointlookup4.q
index ba25301..5eaa58e 100644
--- a/ql/src/test/queries/clientpositive/pointlookup4.q
+++ b/ql/src/test/queries/clientpositive/pointlookup4.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table pcr_t1;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd1.q 
b/ql/src/test/queries/clientpositive/ppd1.q
index a5a4db0..0c9c407 100644
--- a/ql/src/test/queries/clientpositive/ppd1.q
+++ b/ql/src/test/queries/clientpositive/ppd1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd2.q 
b/ql/src/test/queries/clientpositive/ppd2.q
index 75eb6a8..39e3170 100644
--- a/ql/src/test/queries/clientpositive/ppd2.q
+++ b/ql/src/test/queries/clientpositive/ppd2.q
@@ -1,3 +1,5 @@
+--! qt:dataset:srcpart
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_clusterby.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_clusterby.q 
b/ql/src/test/queries/clientpositive/ppd_clusterby.q
index 0c8b245..a4cfe21 100644
--- a/ql/src/test/queries/clientpositive/ppd_clusterby.q
+++ b/ql/src/test/queries/clientpositive/ppd_clusterby.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_constant_expr.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_constant_expr.q 
b/ql/src/test/queries/clientpositive/ppd_constant_expr.q
index 14518e8..11e562f 100644
--- a/ql/src/test/queries/clientpositive/ppd_constant_expr.q
+++ b/ql/src/test/queries/clientpositive/ppd_constant_expr.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src1
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_constant_where.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_constant_where.q 
b/ql/src/test/queries/clientpositive/ppd_constant_where.q
index 0c10235..b55df0c 100644
--- a/ql/src/test/queries/clientpositive/ppd_constant_where.q
+++ b/ql/src/test/queries/clientpositive/ppd_constant_where.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 -- Test that the partition pruner does not fail when there is a constant 
expression in the filter
 
 EXPLAIN SELECT COUNT(*) FROM srcpart WHERE ds = '2008-04-08' and 'a' = 'a';

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_gby.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_gby.q 
b/ql/src/test/queries/clientpositive/ppd_gby.q
index e027544..8806f2e 100644
--- a/ql/src/test/queries/clientpositive/ppd_gby.q
+++ b/ql/src/test/queries/clientpositive/ppd_gby.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_gby2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_gby2.q 
b/ql/src/test/queries/clientpositive/ppd_gby2.q
index 689a0d3..a824740 100644
--- a/ql/src/test/queries/clientpositive/ppd_gby2.q
+++ b/ql/src/test/queries/clientpositive/ppd_gby2.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_gby_join.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_gby_join.q 
b/ql/src/test/queries/clientpositive/ppd_gby_join.q
index e074ae4..51b5d43 100644
--- a/ql/src/test/queries/clientpositive/ppd_gby_join.q
+++ b/ql/src/test/queries/clientpositive/ppd_gby_join.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_join.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_join.q 
b/ql/src/test/queries/clientpositive/ppd_join.q
index 8e68518..78757d2 100644
--- a/ql/src/test/queries/clientpositive/ppd_join.q
+++ b/ql/src/test/queries/clientpositive/ppd_join.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_join2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_join2.q 
b/ql/src/test/queries/clientpositive/ppd_join2.q
index 1aee943..5a5d7a2 100644
--- a/ql/src/test/queries/clientpositive/ppd_join2.q
+++ b/ql/src/test/queries/clientpositive/ppd_join2.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_join3.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_join3.q 
b/ql/src/test/queries/clientpositive/ppd_join3.q
index d7bd4db..6ca1f1d 100644
--- a/ql/src/test/queries/clientpositive/ppd_join3.q
+++ b/ql/src/test/queries/clientpositive/ppd_join3.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_join5.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_join5.q 
b/ql/src/test/queries/clientpositive/ppd_join5.q
index f637155..b13e359 100644
--- a/ql/src/test/queries/clientpositive/ppd_join5.q
+++ b/ql/src/test/queries/clientpositive/ppd_join5.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 create table t1 (id1 string, id2 string);
 create table t2 (id string, d int);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_join_filter.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_join_filter.q 
b/ql/src/test/queries/clientpositive/ppd_join_filter.q
index e909b3d..03cd8ce 100644
--- a/ql/src/test/queries/clientpositive/ppd_join_filter.q
+++ b/ql/src/test/queries/clientpositive/ppd_join_filter.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_multi_insert.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_multi_insert.q 
b/ql/src/test/queries/clientpositive/ppd_multi_insert.q
index 775cefc..9bec0bc 100644
--- a/ql/src/test/queries/clientpositive/ppd_multi_insert.q
+++ b/ql/src/test/queries/clientpositive/ppd_multi_insert.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_outer_join1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_outer_join1.q 
b/ql/src/test/queries/clientpositive/ppd_outer_join1.q
index 30f5b84..5f9373a 100644
--- a/ql/src/test/queries/clientpositive/ppd_outer_join1.q
+++ b/ql/src/test/queries/clientpositive/ppd_outer_join1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_outer_join2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_outer_join2.q 
b/ql/src/test/queries/clientpositive/ppd_outer_join2.q
index b7c8833..c3d2661 100644
--- a/ql/src/test/queries/clientpositive/ppd_outer_join2.q
+++ b/ql/src/test/queries/clientpositive/ppd_outer_join2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_outer_join3.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_outer_join3.q 
b/ql/src/test/queries/clientpositive/ppd_outer_join3.q
index 930803c..6bb43b7 100644
--- a/ql/src/test/queries/clientpositive/ppd_outer_join3.q
+++ b/ql/src/test/queries/clientpositive/ppd_outer_join3.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_outer_join4.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_outer_join4.q 
b/ql/src/test/queries/clientpositive/ppd_outer_join4.q
index e3aaa0e..a11a666 100644
--- a/ql/src/test/queries/clientpositive/ppd_outer_join4.q
+++ b/ql/src/test/queries/clientpositive/ppd_outer_join4.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_random.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_random.q 
b/ql/src/test/queries/clientpositive/ppd_random.q
index 341f5f1..787bb57 100644
--- a/ql/src/test/queries/clientpositive/ppd_random.q
+++ b/ql/src/test/queries/clientpositive/ppd_random.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_transform.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_transform.q 
b/ql/src/test/queries/clientpositive/ppd_transform.q
index cd416ff..e9192cc 100644
--- a/ql/src/test/queries/clientpositive/ppd_transform.q
+++ b/ql/src/test/queries/clientpositive/ppd_transform.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;
 set hive.entity.capture.transform=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_udf_case.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_udf_case.q 
b/ql/src/test/queries/clientpositive/ppd_udf_case.q
index 2aad141..bf8ddcd 100644
--- a/ql/src/test/queries/clientpositive/ppd_udf_case.q
+++ b/ql/src/test/queries/clientpositive/ppd_udf_case.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_udf_col.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_udf_col.q 
b/ql/src/test/queries/clientpositive/ppd_udf_col.q
index 451edd5..9c7d4fd 100644
--- a/ql/src/test/queries/clientpositive/ppd_udf_col.q
+++ b/ql/src/test/queries/clientpositive/ppd_udf_col.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_udtf.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_udtf.q 
b/ql/src/test/queries/clientpositive/ppd_udtf.q
index d90532c..1210f36 100644
--- a/ql/src/test/queries/clientpositive/ppd_udtf.q
+++ b/ql/src/test/queries/clientpositive/ppd_udtf.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 explain
 SELECT value from (
   select explode(array(key, value)) as (value) from (

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_union.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_union.q 
b/ql/src/test/queries/clientpositive/ppd_union.q
index ca1ff40..de15daa 100644
--- a/ql/src/test/queries/clientpositive/ppd_union.q
+++ b/ql/src/test/queries/clientpositive/ppd_union.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_union_view.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_union_view.q 
b/ql/src/test/queries/clientpositive/ppd_union_view.q
index 08b4fce..8302868 100644
--- a/ql/src/test/queries/clientpositive/ppd_union_view.q
+++ b/ql/src/test/queries/clientpositive/ppd_union_view.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 -- test predicate pushdown on a view with a union
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_vc.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_vc.q 
b/ql/src/test/queries/clientpositive/ppd_vc.q
index 0bb949d..a3abf7b 100644
--- a/ql/src/test/queries/clientpositive/ppd_vc.q
+++ b/ql/src/test/queries/clientpositive/ppd_vc.q
@@ -1,3 +1,5 @@
+--! qt:dataset:srcpart
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 --HIVE-3926 PPD on virtual column of partitioned table is not working
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_windowing1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_windowing1.q 
b/ql/src/test/queries/clientpositive/ppd_windowing1.q
index f380eab..e7d74fd 100644
--- a/ql/src/test/queries/clientpositive/ppd_windowing1.q
+++ b/ql/src/test/queries/clientpositive/ppd_windowing1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppd_windowing2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppd_windowing2.q 
b/ql/src/test/queries/clientpositive/ppd_windowing2.q
index abfe89e..4f045a4 100644
--- a/ql/src/test/queries/clientpositive/ppd_windowing2.q
+++ b/ql/src/test/queries/clientpositive/ppd_windowing2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 set hive.ppd.remove.duplicatefilters=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppr_allchildsarenull.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppr_allchildsarenull.q 
b/ql/src/test/queries/clientpositive/ppr_allchildsarenull.q
index 6146073..5345c51 100644
--- a/ql/src/test/queries/clientpositive/ppr_allchildsarenull.q
+++ b/ql/src/test/queries/clientpositive/ppr_allchildsarenull.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppr_pushdown.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppr_pushdown.q 
b/ql/src/test/queries/clientpositive/ppr_pushdown.q
index a3e6d6e..c721744 100644
--- a/ql/src/test/queries/clientpositive/ppr_pushdown.q
+++ b/ql/src/test/queries/clientpositive/ppr_pushdown.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.fetch.task.conversion=more;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppr_pushdown2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppr_pushdown2.q 
b/ql/src/test/queries/clientpositive/ppr_pushdown2.q
index 8c60906..68e5ade 100644
--- a/ql/src/test/queries/clientpositive/ppr_pushdown2.q
+++ b/ql/src/test/queries/clientpositive/ppr_pushdown2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.fetch.task.conversion=more;
 
 create table ppr_test (key string) partitioned by (ds string);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ppr_pushdown3.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ppr_pushdown3.q 
b/ql/src/test/queries/clientpositive/ppr_pushdown3.q
index 35c11be..40f91de 100644
--- a/ql/src/test/queries/clientpositive/ppr_pushdown3.q
+++ b/ql/src/test/queries/clientpositive/ppr_pushdown3.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 set hive.mapred.mode=nonstrict;
 
 explain select * from srcpart where key < 10;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/print_header.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/print_header.q 
b/ql/src/test/queries/clientpositive/print_header.q
index 9deeb1d..aa7e1e0 100644
--- a/ql/src/test/queries/clientpositive/print_header.q
+++ b/ql/src/test/queries/clientpositive/print_header.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 
 set hive.cli.print.header=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ptf.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ptf.q 
b/ql/src/test/queries/clientpositive/ptf.q
index 5ab6cdc..bcdbaab 100644
--- a/ql/src/test/queries/clientpositive/ptf.q
+++ b/ql/src/test/queries/clientpositive/ptf.q
@@ -1,3 +1,4 @@
+--! qt:dataset:part
 set hive.explain.user=false;
 -- SORT_QUERY_RESULTS
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ptf_decimal.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ptf_decimal.q 
b/ql/src/test/queries/clientpositive/ptf_decimal.q
index 94885e3..8eea0e7 100644
--- a/ql/src/test/queries/clientpositive/ptf_decimal.q
+++ b/ql/src/test/queries/clientpositive/ptf_decimal.q
@@ -1,3 +1,4 @@
+--! qt:dataset:part
 -- SORT_QUERY_RESULTS
 
 -- 1. aggregate functions with decimal type

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ptf_general_queries.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ptf_general_queries.q 
b/ql/src/test/queries/clientpositive/ptf_general_queries.q
index 9942063..0ab756e 100644
--- a/ql/src/test/queries/clientpositive/ptf_general_queries.q
+++ b/ql/src/test/queries/clientpositive/ptf_general_queries.q
@@ -1,3 +1,4 @@
+--! qt:dataset:part
 -- SORT_QUERY_RESULTS
 
 -- 1. testNoPTFNoWindowing

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ptf_rcfile.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ptf_rcfile.q 
b/ql/src/test/queries/clientpositive/ptf_rcfile.q
index 501d2a4..1bed12b 100644
--- a/ql/src/test/queries/clientpositive/ptf_rcfile.q
+++ b/ql/src/test/queries/clientpositive/ptf_rcfile.q
@@ -1,3 +1,4 @@
+--! qt:dataset:part
 DROP TABLE part_rc;
 
 CREATE TABLE part_rc( 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ptf_seqfile.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ptf_seqfile.q 
b/ql/src/test/queries/clientpositive/ptf_seqfile.q
index ac55714..d59665f 100644
--- a/ql/src/test/queries/clientpositive/ptf_seqfile.q
+++ b/ql/src/test/queries/clientpositive/ptf_seqfile.q
@@ -1,3 +1,4 @@
+--! qt:dataset:part
 DROP TABLE part_seq;
 
 CREATE TABLE part_seq( 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ptf_streaming.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ptf_streaming.q 
b/ql/src/test/queries/clientpositive/ptf_streaming.q
index aa70a5c..5d7e531 100644
--- a/ql/src/test/queries/clientpositive/ptf_streaming.q
+++ b/ql/src/test/queries/clientpositive/ptf_streaming.q
@@ -1,3 +1,4 @@
+--! qt:dataset:part
 set hive.explain.user=false;
 -- SORT_QUERY_RESULTS
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/push_or.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/push_or.q 
b/ql/src/test/queries/clientpositive/push_or.q
index c962452..8de259d 100644
--- a/ql/src/test/queries/clientpositive/push_or.q
+++ b/ql/src/test/queries/clientpositive/push_or.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 drop table push_or;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx.q 
b/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx.q
index 240e74e..36da289 100644
--- a/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx.q
+++ b/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx.q
@@ -1,3 +1,5 @@
+--! qt:dataset:srcpart
+--! qt:dataset:lineitem
 set hive.stats.dbclass=fs;
 set hive.stats.autogather=true;
 set hive.cbo.enable=false;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_1.q 
b/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_1.q
index 82e67ab..0941493 100644
--- a/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_1.q
+++ b/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_1.q
@@ -1,3 +1,5 @@
+--! qt:dataset:srcpart
+--! qt:dataset:lineitem
 set hive.stats.dbclass=fs;
 set hive.stats.autogather=true;
 set hive.cbo.enable=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_2.q 
b/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_2.q
index cfc5b0c..14197f4 100644
--- a/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_2.q
+++ b/ql/src/test/queries/clientpositive/ql_rewrite_gbtoidx_cbo_2.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src
+--! qt:dataset:lineitem
 set hive.stats.dbclass=fs;
 set hive.stats.autogather=true;
 set hive.cbo.enable=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/query_lifetime_hook.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/query_lifetime_hook.q 
b/ql/src/test/queries/clientpositive/query_lifetime_hook.q
index 6793faa..5b6ffb7 100644
--- a/ql/src/test/queries/clientpositive/query_lifetime_hook.q
+++ b/ql/src/test/queries/clientpositive/query_lifetime_hook.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 SET 
hive.query.lifetime.hooks=org.apache.hadoop.hive.ql.hooks.QueryLifeTimeHookTest;
 
 SELECT * FROM src LIMIT 1;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/query_properties.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/query_properties.q 
b/ql/src/test/queries/clientpositive/query_properties.q
index 78ac32d..1449a4f 100644
--- a/ql/src/test/queries/clientpositive/query_properties.q
+++ b/ql/src/test/queries/clientpositive/query_properties.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.cbo.enable=false;
 set hive.exec.post.hooks = 
org.apache.hadoop.hive.ql.hooks.CheckQueryPropertiesHook;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/query_result_fileformat.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/query_result_fileformat.q 
b/ql/src/test/queries/clientpositive/query_result_fileformat.q
index 3b87e4d..a4c63e1 100644
--- a/ql/src/test/queries/clientpositive/query_result_fileformat.q
+++ b/ql/src/test/queries/clientpositive/query_result_fileformat.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 create table nzhang_test1 stored as sequencefile as select 'key1' as key, 
'value
 1
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/query_with_semi.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/query_with_semi.q 
b/ql/src/test/queries/clientpositive/query_with_semi.q
index e0f90d5..646bd6f 100644
--- a/ql/src/test/queries/clientpositive/query_with_semi.q
+++ b/ql/src/test/queries/clientpositive/query_with_semi.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 from src
 select transform('aa\;') using 'cat' as a  limit 1;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/quote1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/quote1.q 
b/ql/src/test/queries/clientpositive/quote1.q
index e46402c..3f38597 100644
--- a/ql/src/test/queries/clientpositive/quote1.q
+++ b/ql/src/test/queries/clientpositive/quote1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 CREATE TABLE dest1(`location` INT, `type` STRING) PARTITIONED BY(`table` 
STRING) STORED AS TEXTFILE;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/quote2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/quote2.q 
b/ql/src/test/queries/clientpositive/quote2.q
index 17cbfca..72599d2 100644
--- a/ql/src/test/queries/clientpositive/quote2.q
+++ b/ql/src/test/queries/clientpositive/quote2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.fetch.task.conversion=more;
 
 EXPLAIN

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/quotedid_alter.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/quotedid_alter.q 
b/ql/src/test/queries/clientpositive/quotedid_alter.q
index a34a25a..441cfc4 100644
--- a/ql/src/test/queries/clientpositive/quotedid_alter.q
+++ b/ql/src/test/queries/clientpositive/quotedid_alter.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 
 set hive.support.quoted.identifiers=column;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/quotedid_basic.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/quotedid_basic.q 
b/ql/src/test/queries/clientpositive/quotedid_basic.q
index a16f6f5..8d6136b 100644
--- a/ql/src/test/queries/clientpositive/quotedid_basic.q
+++ b/ql/src/test/queries/clientpositive/quotedid_basic.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 
 set hive.support.quoted.identifiers=column;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/quotedid_partition.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/quotedid_partition.q 
b/ql/src/test/queries/clientpositive/quotedid_partition.q
index 67eca10..34c40ca 100644
--- a/ql/src/test/queries/clientpositive/quotedid_partition.q
+++ b/ql/src/test/queries/clientpositive/quotedid_partition.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 
 set hive.support.quoted.identifiers=column;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/quotedid_smb.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/quotedid_smb.q 
b/ql/src/test/queries/clientpositive/quotedid_smb.q
index 11642f5..acc7626 100644
--- a/ql/src/test/queries/clientpositive/quotedid_smb.q
+++ b/ql/src/test/queries/clientpositive/quotedid_smb.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 
 set hive.support.quoted.identifiers=column;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rand_partitionpruner1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rand_partitionpruner1.q 
b/ql/src/test/queries/clientpositive/rand_partitionpruner1.q
index 3eeb5e7..42ca756 100644
--- a/ql/src/test/queries/clientpositive/rand_partitionpruner1.q
+++ b/ql/src/test/queries/clientpositive/rand_partitionpruner1.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 -- scanning un-partitioned data
 explain extended select * from src where rand(1) < 0.1;
 select * from src where rand(1) < 0.1;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rand_partitionpruner2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rand_partitionpruner2.q 
b/ql/src/test/queries/clientpositive/rand_partitionpruner2.q
index e2f280e..05da3d4 100644
--- a/ql/src/test/queries/clientpositive/rand_partitionpruner2.q
+++ b/ql/src/test/queries/clientpositive/rand_partitionpruner2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 -- scanning partitioned data
 
 create table tmptable(key string, value string, hr string, ds string);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rand_partitionpruner3.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rand_partitionpruner3.q 
b/ql/src/test/queries/clientpositive/rand_partitionpruner3.q
index 481ba08..004e1a1 100644
--- a/ql/src/test/queries/clientpositive/rand_partitionpruner3.q
+++ b/ql/src/test/queries/clientpositive/rand_partitionpruner3.q
@@ -1,3 +1,4 @@
+--! qt:dataset:srcpart
 set hive.mapred.mode=nonstrict;
 set hive.optimize.ppd=true;
 -- complex predicates in the where clause

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_bigdata.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_bigdata.q 
b/ql/src/test/queries/clientpositive/rcfile_bigdata.q
index df460c8..dda8ecf 100644
--- a/ql/src/test/queries/clientpositive/rcfile_bigdata.q
+++ b/ql/src/test/queries/clientpositive/rcfile_bigdata.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.map.aggr.hash.percentmemory = 0.3;
 set hive.mapred.local.mem = 256;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_columnar.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_columnar.q 
b/ql/src/test/queries/clientpositive/rcfile_columnar.q
index 5fd94e7..ca1ba4a 100644
--- a/ql/src/test/queries/clientpositive/rcfile_columnar.q
+++ b/ql/src/test/queries/clientpositive/rcfile_columnar.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 
 CREATE table columnTable (key STRING, value STRING)

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_createas1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_createas1.q 
b/ql/src/test/queries/clientpositive/rcfile_createas1.q
index 200c0ec..eb017e3 100644
--- a/ql/src/test/queries/clientpositive/rcfile_createas1.q
+++ b/ql/src/test/queries/clientpositive/rcfile_createas1.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src
+--! qt:dataset:part
 set hive.mapred.mode=nonstrict;
 set hive.merge.rcfile.block.level=true;
 set mapred.max.split.size=100;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_default_format.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_default_format.q 
b/ql/src/test/queries/clientpositive/rcfile_default_format.q
index e61292e..5c03510 100644
--- a/ql/src/test/queries/clientpositive/rcfile_default_format.q
+++ b/ql/src/test/queries/clientpositive/rcfile_default_format.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 SET hive.default.fileformat = RCFile;
 
 CREATE TABLE rcfile_default_format (key STRING);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_lazydecompress.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_lazydecompress.q 
b/ql/src/test/queries/clientpositive/rcfile_lazydecompress.q
index a6d39c4..9de7dd5 100644
--- a/ql/src/test/queries/clientpositive/rcfile_lazydecompress.q
+++ b/ql/src/test/queries/clientpositive/rcfile_lazydecompress.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 
 CREATE table rcfileTableLazyDecompress (key STRING, value STRING) STORED AS 
RCFile;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_merge1.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_merge1.q 
b/ql/src/test/queries/clientpositive/rcfile_merge1.q
index 1f6f1bd..d72cfa3 100644
--- a/ql/src/test/queries/clientpositive/rcfile_merge1.q
+++ b/ql/src/test/queries/clientpositive/rcfile_merge1.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src
+--! qt:dataset:part
 set hive.merge.rcfile.block.level=false;
 set hive.exec.dynamic.partition=true;
 set mapred.max.split.size=100;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_merge2.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_merge2.q 
b/ql/src/test/queries/clientpositive/rcfile_merge2.q
index f5b7add..f3051ec 100644
--- a/ql/src/test/queries/clientpositive/rcfile_merge2.q
+++ b/ql/src/test/queries/clientpositive/rcfile_merge2.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.merge.rcfile.block.level=true;
 set hive.exec.dynamic.partition=true;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_merge3.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_merge3.q 
b/ql/src/test/queries/clientpositive/rcfile_merge3.q
index 25d115c..fa30ee7 100644
--- a/ql/src/test/queries/clientpositive/rcfile_merge3.q
+++ b/ql/src/test/queries/clientpositive/rcfile_merge3.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.merge.rcfile.block.level=true;
 set mapred.max.split.size=100;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_merge4.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_merge4.q 
b/ql/src/test/queries/clientpositive/rcfile_merge4.q
index cf18f80..95e0f9b 100644
--- a/ql/src/test/queries/clientpositive/rcfile_merge4.q
+++ b/ql/src/test/queries/clientpositive/rcfile_merge4.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.merge.rcfile.block.level=true;
 set mapred.max.split.size=100;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_null_value.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_null_value.q 
b/ql/src/test/queries/clientpositive/rcfile_null_value.q
index 5ef80a7..da64b6e 100644
--- a/ql/src/test/queries/clientpositive/rcfile_null_value.q
+++ b/ql/src/test/queries/clientpositive/rcfile_null_value.q
@@ -1,3 +1,5 @@
+--! qt:dataset:src1
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 CREATE TABLE src1_rc(key STRING, value STRING) STORED AS RCFILE;
 INSERT OVERWRITE TABLE src1_rc SELECT * FROM src1;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_toleratecorruptions.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_toleratecorruptions.q 
b/ql/src/test/queries/clientpositive/rcfile_toleratecorruptions.q
index cd3267f..1344a60 100644
--- a/ql/src/test/queries/clientpositive/rcfile_toleratecorruptions.q
+++ b/ql/src/test/queries/clientpositive/rcfile_toleratecorruptions.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 CREATE TABLE test_src(key int, value string) stored as RCFILE;
 set hive.io.rcfile.record.interval=5;

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/rcfile_union.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/rcfile_union.q 
b/ql/src/test/queries/clientpositive/rcfile_union.q
index 8308acc..5547c1f 100644
--- a/ql/src/test/queries/clientpositive/rcfile_union.q
+++ b/ql/src/test/queries/clientpositive/rcfile_union.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 
 CREATE table rcfile_unionTable (b STRING, c STRING)

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/recursive_dir.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/recursive_dir.q 
b/ql/src/test/queries/clientpositive/recursive_dir.q
index d703b8e..eea365d 100644
--- a/ql/src/test/queries/clientpositive/recursive_dir.q
+++ b/ql/src/test/queries/clientpositive/recursive_dir.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 -- INCLUDE_HADOOP_MAJOR_VERSIONS(0.23)
 
 CREATE TABLE fact_daily(x int) PARTITIONED BY (ds STRING);

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/reduceSinkDeDuplication_pRS_key_empty.q
----------------------------------------------------------------------
diff --git 
a/ql/src/test/queries/clientpositive/reduceSinkDeDuplication_pRS_key_empty.q 
b/ql/src/test/queries/clientpositive/reduceSinkDeDuplication_pRS_key_empty.q
index d72fad5..f922295 100644
--- a/ql/src/test/queries/clientpositive/reduceSinkDeDuplication_pRS_key_empty.q
+++ b/ql/src/test/queries/clientpositive/reduceSinkDeDuplication_pRS_key_empty.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.mapred.mode=nonstrict;
 set hive.cbo.enable=false;
 

http://git-wip-us.apache.org/repos/asf/hive/blob/86b678f5/ql/src/test/queries/clientpositive/reduce_deduplicate.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/reduce_deduplicate.q 
b/ql/src/test/queries/clientpositive/reduce_deduplicate.q
index 5386590..7581982 100644
--- a/ql/src/test/queries/clientpositive/reduce_deduplicate.q
+++ b/ql/src/test/queries/clientpositive/reduce_deduplicate.q
@@ -1,3 +1,4 @@
+--! qt:dataset:src
 set hive.input.format=org.apache.hadoop.hive.ql.io.HiveInputFormat;
 ;
 set hive.exec.reducers.max = 1;

Reply via email to