[
https://issues.apache.org/jira/browse/IMPALA-15039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Rozsa reassigned IMPALA-15039:
------------------------------------
Assignee: Michael Smith
> 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
> Assignee: Michael Smith
> Priority: Minor
> Labels: broken-build
>
> 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)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
