Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
Impala 4.5.0
-
None
-
ghx-label-1
Description
TestTPCHJoinQueries.test_outer_joins run tpch-outer-joins.test, which have following drop/create table query.
drop table if exists default.t1; drop table if exists default.t2; create table default.t1(`insert` bigint); create table default.t2(`select` bigint);
If two test_outer_joins with different test vector run concurrently, one of them can hit AnalysisException as follows:
query_test/test_join_queries.py:180: in test_outer_joins self.run_test_case('tpch-outer-joins', vector) common/impala_test_suite.py:807: in run_test_case user=test_section.get('USER', '').strip() or None) common/impala_test_suite.py:726: in __exec_in_impala result = self.__execute_query(target_impalad_client, query, user=user) common/impala_test_suite.py:1097: in __execute_query return impalad_client.execute(query, user=user) common/impala_connection.py:220: in execute fetch_profile_after_close=fetch_profile_after_close) beeswax/impala_beeswax.py:190: in execute handle = self.__execute_query(query_string.strip(), user=user) beeswax/impala_beeswax.py:381: in __execute_query handle = self.execute_query_async(query_string, user=user) beeswax/impala_beeswax.py:375: in execute_query_async handle = self.__do_rpc(lambda: self.imp_service.query(query,)) beeswax/impala_beeswax.py:553: in __do_rpc raise ImpalaBeeswaxException(self.__build_error_message(b), b) E ImpalaBeeswaxException: Query 65446c2aeefc64b1:f305c36400000000 failed: E AnalysisException: Table already exists: default.t1
Both t1 and t2 table in test case should be created using unique database.