Laszlo Gaal created IMPALA-15755:
------------------------------------
Summary: custom_cluster test
test_topic_updates_block_legacy_catalog_sync_ddl_create_table fails on Ozone
Key: IMPALA-15755
URL: https://issues.apache.org/jira/browse/IMPALA-15755
Project: IMPALA
Issue Type: Bug
Components: Catalog
Affects Versions: Impala 5.1.0
Reporter: Laszlo Gaal
Test:
custom_cluster.test_topic_update_frequency.TestTopicUpdateFrequency.test_topic_updates_block_legacy_catalog
Error Details:
{code}
AssertionError: describe functional.emptytable completed within 2000 msec
assert 156 > 2000
+ where 156 = <bound method ApplyResult.get of
<multiprocessing.pool.ApplyResult object at 0x7efd4d28da50>>()
+ where <bound method ApplyResult.get of <multiprocessing.pool.ApplyResult
object at 0x7efd4d28da50>> = <multiprocessing.pool.ApplyResult object at
0x7efd4d28da50>.get
{code}
Stack trace{code}
custom_cluster/test_topic_update_frequency.py:34: in
test_topic_updates_block_legacy_catalog
self.__run_topic_update_test(expect_topic_updates_to_block=True)
self =
<tests.custom_cluster.test_topic_update_frequency.TestTopicUpdateFrequency
object at 0x7efcc1b08890>
custom_cluster/test_topic_update_frequency.py:120: in __run_topic_update_test
self.__run_topic_update_test_inner(blocking_query,
blocking_queries = ['refresh tpcds.store_sales', 'alter table
tpcds.store_sales recover partitions', 'compute stats functional.alltypes']
blocking_query = 'compute stats functional.alltypes'
blocking_query_options = {'debug_action':
'catalogd_refresh_hdfs_listing_delay:SLEEP@12|catalogd_table_recover_delay:SLEEP@4000|catalogd_update_stats_delay:SLEEP@4000',
'sync_ddl': 'false'}
blocking_sync_ddl = 'false'
debug_action =
'catalogd_refresh_hdfs_listing_delay:SLEEP@12|catalogd_table_recover_delay:SLEEP@4000|catalogd_update_stats_delay:SLEEP@4000'
expect_topic_updates_to_block = True
init_queries = ['invalidate metadata functional.emptytable',
'invalidate metadata functional.tinytable', 'invalidate metadata
functional.alltypessmall']
non_blocking_queries = ['describe functional.emptytable', 'select *
from functional.tinytable limit 1', 'show partitions functional.alltypessmall']
non_blocking_query_options = {'sync_ddl': 'false'}
non_blocking_sync_ddl = 'false'
self =
<tests.custom_cluster.test_topic_update_frequency.TestTopicUpdateFrequency
object at 0x7efcc1b08890>
custom_cluster/test_topic_update_frequency.py:220: in
__run_topic_update_test_inner
assert fast_query_futures[fast_query].get() > fast_query_timeout_ms, \
E AssertionError: describe functional.emptytable completed within 2000 msec
E assert 156 > 2000
E + where 156 = <bound method ApplyResult.get of
<multiprocessing.pool.ApplyResult object at 0x7efd4d28da50>>()
E + where <bound method ApplyResult.get of
<multiprocessing.pool.ApplyResult object at 0x7efd4d28da50>> =
<multiprocessing.pool.ApplyResult object at 0x7efd4d28da50>.get
blocking_query_min_time = 4000
blocking_query_options = {'debug_action':
'catalogd_refresh_hdfs_listing_delay:SLEEP@12|catalogd_table_recover_delay:SLEEP@4000|catalogd_update_stats_delay:SLEEP@4000',
'sync_ddl': 'false'}
expect_topic_updates_to_block = True
fast_queries = ['describe functional.emptytable', 'select * from
functional.tinytable limit 1', 'show partitions functional.alltypessmall']
fast_query = 'describe functional.emptytable'
fast_query_futures = {'describe functional.emptytable':
<multiprocessing.pool.ApplyResult object at 0x7efd4d28da50>, 'select * from
functio...7efd4d28cf90>, 'show partitions functional.alltypessmall':
<multiprocessing.pool.ApplyResult object at 0x7efd4d28d550>}
fast_query_timeout_ms = 2000
init_queries = ['invalidate metadata functional.emptytable',
'invalidate metadata functional.tinytable', 'invalidate metadata
functional.alltypessmall']
non_blocking_impalad = 0
non_blocking_query_options = {'sync_ddl': 'false'}
pool = <multiprocessing.pool.ThreadPool state=RUN pool_size=3>
q = 'invalidate metadata functional.alltypessmall'
self =
<tests.custom_cluster.test_topic_update_frequency.TestTopicUpdateFrequency
object at 0x7efcc1b08890>
slow_blocking_query = 'compute stats functional.alltypes'
slow_query_future = <multiprocessing.pool.ApplyResult object at
0x7efd4d1e2b50>
slow_query_pool = <multiprocessing.pool.ThreadPool state=RUN
pool_size=1>{code}
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
