jprdonnelly/impala
1
0
Fork 0
mirror of https://github.com/apache/impala.git synced 2025-12-25 02:03:09 -05:00
Code Issues Projects Releases Wiki Activity

IMPALA-13880: Skip Iceberg interop tests with Hive if the default filesystem is not HDFS

Browse Source 
This patch adds skip annotations to the tests added by IMPALA-13611 if
the targeted filesystem is not HDFS. 'run-all.sh' starts just the Hive
Metastore in case the targeted filesystem is not HDFS.

Test:
 - manually validated that the test is skipped if the default filesystem
points to an Ozone instance.

Change-Id: Ic872f31f0d4b61fbe0479a32c8a6c52fde6b293e
Reviewed-on: http://gerrit.cloudera.org:8080/22651
Reviewed-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com>
Tested-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com>
This commit is contained in:
Peter Rozsa
2025-03-20 20:07:21 +01:00
committed by Impala Public Jenkins
parent ea8f74a6ac
commit 6f949718f5
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
tests/stress/test_update_stress.py
View File

@@ -25,6 +25,7 @@ from subprocess import check_output
from tests.common.impala_test_suite import ImpalaTestSuite
from tests.common.parametrize import UniqueDatabase
from tests.common.skip import SkipIfFS
from tests.common.test_dimensions import create_exec_option_dimension
from tests.stress.stress_util import run_tasks, Task
from tests.util.filesystem_utils import FILESYSTEM_PREFIX, IS_HDFS
@@ -352,6 +353,7 @@ class TestIcebergConcurrentOperations(ImpalaTestSuite):
assert len(data_files_in_tbl) == len(data_files_on_fs_rows)
assert set(data_files_on_fs) == set(data_files_in_tbl)
@SkipIfFS.hive
@pytest.mark.execute_serially
@UniqueDatabase.parametrize(sync_ddl=True)
def test_iceberg_impala_deletes_and_hive_updates(self, unique_database):
@@ -380,6 +382,7 @@ class TestIcebergConcurrentOperations(ImpalaTestSuite):
result = self.client.execute("select count(*) from {}".format(tbl_name))
assert result.data == ['0']
@SkipIfFS.hive
@pytest.mark.execute_serially
@UniqueDatabase.parametrize(sync_ddl=True)
def test_iceberg_impala_updates_and_hive_deletes(self, unique_database):