Peter Rozsa created IMPALA-15039:
------------------------------------
Summary:
statestore.test_statestore.TestStatestore.test_filter_prefix fails in ASAN
builds
Key: IMPALA-15039
URL: https://issues.apache.org/jira/browse/IMPALA-15039
Project: IMPALA
Issue Type: Bug
Components: Test
Reporter: Peter Rozsa
statestore.test_statestore.TestStatestore.test_filter_prefix fails in ASAN
builds
Socket probing was rewritten in [https://gerrit.cloudera.org/c/24061/]
Stacktrace:
{code:java}
statestore/test_statestore.py:481: in test_filter_prefix
.wait_for_update(topic_name, 5)
reg =
TTopicRegistration(topic_name='topic_delta_e0dc9f73-57e5-11f1-95ba-064243d83d83',
is_transient=False, populate_min_subscriber_topic_version=False,
filter_prefix='bar')
self = <test_statestore.TestStatestore object at 0x7f47643fe790>
sub = <test_statestore.StatestoreSubscriber object at
0x7f4764271850>
topic_name = 'topic_delta_e0dc9f73-57e5-11f1-95ba-064243d83d83'
topic_update_correct = <function
TestStatestore.test_filter_prefix.<locals>.topic_update_correct at
0x7f47642e2c00>
statestore/test_statestore.py:355: in wait_for_update
raise Exception(
E Exception: Update not received for
topic_delta_e0dc9f73-57e5-11f1-95ba-064243d83d83 within 40 (update count: 0)
count = 5
last_count = 0
self = <test_statestore.StatestoreSubscriber object at
0x7f4764271850>
start_time = 1779678025.6933134
topic_name = 'topic_delta_e0dc9f73-57e5-11f1-95ba-064243d83d83'
During handling of the above exception, another exception occurred:
statestore/test_statestore.py:475: in test_filter_prefix
with StatestoreSubscriber(update_cb=topic_update_correct) as sub:
reg =
TTopicRegistration(topic_name='topic_delta_e0dc9f73-57e5-11f1-95ba-064243d83d83',
is_transient=False, populate_min_subscriber_topic_version=False,
filter_prefix='bar')
self = <test_statestore.TestStatestore object at 0x7f47643fe790>
sub = <test_statestore.StatestoreSubscriber object at
0x7f4764271850>
topic_name = 'topic_delta_e0dc9f73-57e5-11f1-95ba-064243d83d83'
topic_update_correct = <function
TestStatestore.test_filter_prefix.<locals>.topic_update_correct at
0x7f47642e2c00>
statestore/test_statestore.py:220: in __exit__
self.kill()
args = (<class 'Exception'>, Exception('Update not received for
topic_delta_e0dc9f73-57e5-11f1-95ba-064243d83d83 within 40 (update count: 0)'),
<traceback object at 0x7f47643a5bc0>)
self = <test_statestore.StatestoreSubscriber object at
0x7f4764271850>
statestore/test_statestore.py:292: in kill
self.server.shutdown()
self = <test_statestore.StatestoreSubscriber object at
0x7f4764271850>
statestore/test_statestore.py:121: in shutdown
self.wait_until_down()
self = <test_statestore.KillableThreadedServer object at
0x7f4764169250>
statestore/test_statestore.py:150: in wait_until_down
raise Exception("Server localhost:{} did not stop".format(cnxn.port))
E Exception: Server localhost:41519 did not stop
cnxn = <thrift.transport.TSocket.TSocket object at 0x7f47643f5710>
i = 9
num_tries = 10
self = <test_statestore.KillableThreadedServer object at
0x7f4764169250> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
