Skip test_hash_groupby_collect_partial_replace_with_distinct_fallback…

… for #7092 [databricks] (#7102) * Temporarily lower parallelism for #7092 Signed-off-by: Peixin Li <[email protected]> * Revert "Temporarily lower parallelism for #7092" This reverts commit c67927b. * XFAIL test_hash_groupby_collect_partial_replace_with_distinct_fallback Signed-off-by: Peixin Li <[email protected]> * skip the case instead of xfail * xfail new case failure Signed-off-by: Peixin Li <[email protected]> Signed-off-by: Peixin Li <[email protected]>
NVIDIA · Nov 18, 2022 · c70bcfb · c70bcfb
1 parent f4f09a8
commit c70bcfb
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/integration_tests/src/main/python/hash_aggregate_test.py b/integration_tests/src/main/python/hash_aggregate_test.py
@@ -731,6 +731,7 @@ def do_it(spark):
 
 @ignore_order(local=True)
 @pytest.mark.parametrize('data_gen', _full_gen_data_for_collect_op, ids=idfn)
+@pytest.mark.xfail(reason='https://github.com/NVIDIA/spark-rapids/issues/7104')
 def test_hash_groupby_collect_with_single_distinct(data_gen):
     # test collect_ops with other distinct aggregations
     assert_gpu_and_cpu_are_equal_collect(
@@ -839,6 +840,7 @@ def test_hash_groupby_collect_partial_replace_fallback(data_gen,
 @pytest.mark.parametrize('aqe_enabled', ['false', 'true'], ids=idfn)
 @pytest.mark.parametrize('use_obj_hash_agg', ['false', 'true'], ids=idfn)
 @pytest.mark.xfail(condition=is_databricks104_or_later(), reason='https://github.com/NVIDIA/spark-rapids/issues/4963')
+@pytest.mark.skip(reason='https://github.com/NVIDIA/spark-rapids/issues/7092')
 def test_hash_groupby_collect_partial_replace_with_distinct_fallback(data_gen,
                                                                      replace_mode,
                                                                      aqe_enabled,