IMPALA-5478: Run TPCDS queries with decimal_v2 enabled

We add new TPCDS .test files that are expected to be run with decimal_v2 enabled. The new expected results were generated using Impala and I inspected them manually. Change-Id: Ib867c51a521ec4a087bc127d99aee4b95ba97733 Reviewed-on: http://gerrit.cloudera.org:8080/8985 Reviewed-by: Michael Brown <mikeb@cloudera.com> Tested-by: Impala Public Jenkins
2025-12-25 02:03:09 -05:00 · 2018-01-08 19:17:44 -08:00
parent d9b6fd0730
commit 35a3e186d6
74 changed files with 14182 additions and 4 deletions
--- a/tests/query_test/test_tpcds_queries.py
+++ b/tests/query_test/test_tpcds_queries.py
@@ -105,9 +105,6 @@ class TestTpcdsQuery(ImpalaTestSuite):
  def test_tpcds_q21(self, vector):
    self.run_test_case(self.get_workload() + '-q21', vector)

-  def test_tpcds_q22a(self, vector):
-    self.run_test_case(self.get_workload() + '-q22a', vector)
-
  def test_tpcds_q25(self, vector):
    self.run_test_case(self.get_workload() + '-q25', vector)

@@ -268,6 +265,246 @@ class TestTpcdsQuery(ImpalaTestSuite):
    self.run_test_case(self.get_workload() + '-q99', vector)


+class TestTpcdsDecimalV2Query(ImpalaTestSuite):
+  @classmethod
+  def get_workload(cls):
+    return 'tpcds'
+
+  @classmethod
+  def add_test_dimensions(cls):
+    super(TestTpcdsDecimalV2Query, cls).add_test_dimensions()
+    cls.ImpalaTestMatrix.add_constraint(lambda v:\
+        v.get_value('table_format').file_format not in ['rc', 'hbase', 'kudu'] and\
+        v.get_value('table_format').compression_codec in ['none', 'snap'] and\
+        v.get_value('table_format').compression_type != 'record')
+    cls.ImpalaTestMatrix.add_mandatory_exec_option('decimal_v2', 1)
+
+    if cls.exploration_strategy() != 'exhaustive':
+      # Cut down on the execution time for these tests in core by running only
+      # against parquet.
+      cls.ImpalaTestMatrix.add_constraint(lambda v:\
+          v.get_value('table_format').file_format in ['parquet'])
+
+    cls.ImpalaTestMatrix.add_constraint(lambda v:\
+        v.get_value('exec_option')['batch_size'] == 0)
+
+  def test_tpcds_q1(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q1', vector)
+
+  def test_tpcds_q2(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q2', vector)
+
+  def test_tpcds_q3(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q3', vector)
+
+  def test_tpcds_q4(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q4', vector)
+
+  def test_tpcds_q6(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q6', vector)
+
+  def test_tpcds_q7(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q7', vector)
+
+  def test_tpcds_q8(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q8', vector)
+
+  def test_tpcds_q10a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q10a', vector)
+
+  def test_tpcds_q11(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q11', vector)
+
+  def test_tpcds_q12(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q12', vector)
+
+  def test_tpcds_q13(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q13', vector)
+
+  def test_tpcds_q15(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q15', vector)
+
+  def test_tpcds_q16(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q16', vector)
+
+  def test_tpcds_q17(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q17', vector)
+
+  def test_tpcds_q18a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q18a', vector)
+
+  def test_tpcds_q19(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q19', vector)
+
+  def test_tpcds_q20(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q20', vector)
+
+  def test_tpcds_q21(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q21', vector)
+
+  def test_tpcds_q22a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q22a', vector)
+
+  def test_tpcds_q25(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q25', vector)
+
+  def test_tpcds_q29(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q29', vector)
+
+  def test_tpcds_q32(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q32', vector)
+
+  def test_tpcds_q33(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q33', vector)
+
+  def test_tpcds_q34(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q34', vector)
+
+  def test_tpcds_q37(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q37', vector)
+
+  def test_tpcds_q39_1(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q39-1', vector)
+
+  def test_tpcds_q39_2(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q39-2', vector)
+
+  def test_tpcds_q40(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q40', vector)
+
+  def test_tpcds_q41(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q41', vector)
+
+  def test_tpcds_q42(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q42', vector)
+
+  def test_tpcds_q43(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q43', vector)
+
+  def test_tpcds_q46(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q46', vector)
+
+  def test_tpcds_q50(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q50', vector)
+
+  def test_tpcds_q51(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q51', vector)
+
+  def test_tpcds_q51a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q51a', vector)
+
+  def test_tpcds_q52(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q52', vector)
+
+  def test_tpcds_q53(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q53', vector)
+
+  def test_tpcds_q54(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q54', vector)
+
+  def test_tpcds_q55(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q55', vector)
+
+  def test_tpcds_q56(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q56', vector)
+
+  def test_tpcds_q60(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q60', vector)
+
+  def test_tpcds_q61(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q61', vector)
+
+  def test_tpcds_q62(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q62', vector)
+
+  def test_tpcds_q64(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q64', vector)
+
+  def test_tpcds_q65(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q65', vector)
+
+  def test_tpcds_q67a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q67a', vector)
+
+  def test_tpcds_q68(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q68', vector)
+
+  def test_tpcds_q69(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q69', vector)
+
+  def test_tpcds_q70a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q70a', vector)
+
+  def test_tpcds_q71(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q71', vector)
+
+  def test_tpcds_q72(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q72', vector)
+
+  def test_tpcds_q73(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q73', vector)
+
+  def test_tpcds_q74(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q74', vector)
+
+  def test_tpcds_q75(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q75', vector)
+
+  def test_tpcds_q76(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q76', vector)
+
+  def test_tpcds_q77a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q77a', vector)
+
+  def test_tpcds_q78(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q78', vector)
+
+  def test_tpcds_q79(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q79', vector)
+
+  def test_tpcds_q80a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q80a', vector)
+
+  def test_tpcds_q81(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q81', vector)
+
+  def test_tpcds_q82(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q82', vector)
+
+  def test_tpcds_q84(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q84', vector)
+
+  def test_tpcds_q86a(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q86a', vector)
+
+  def test_tpcds_q88(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q88', vector)
+
+  def test_tpcds_q91(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q91', vector)
+
+  def test_tpcds_q92(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q92', vector)
+
+  def test_tpcds_q94(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q94', vector)
+
+  def test_tpcds_q95(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q95', vector)
+
+  def test_tpcds_q96(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q96', vector)
+
+  def test_tpcds_q97(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q97', vector)
+
+  def test_tpcds_q98(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q98', vector)
+
+  def test_tpcds_q99(self, vector):
+    self.run_test_case(self.get_workload() + '-decimal_v2-q99', vector)
+
+
 class TestTpcdsInsert(ImpalaTestSuite):
  @classmethod
  def get_workload(self):