[ 
https://issues.apache.org/jira/browse/IMPALA-10596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312587#comment-17312587
 ] 

Bikramjeet Vig commented on IMPALA-10596:
-----------------------------------------

So I tried to simulate this on my local by introducing a failed assert right 
after we call self.wait_for_admitted_threads(metric_deltas['admitted']) and the 
log line "Found all 6 admitted threads after 0.0 seconds" is printed. I noticed 
that teardown is not called right away and instead all the running threads are 
just waiting in the  "while not self.shutdown" loop and when they error out of 
that, the client gets closed and eventually teardown is called which then 
errors out since the query_id was already closed when the client closed.
I'll push out a patch that removes the thread.query_handle if the client is 
closed. That should fix this issue *and expose the real assert which was hit 
that failed the test*. However, I am still not sure why the test just keeps 
waiting for the other threads to finish before calling teardown.

> TestAdmissionControllerStressWithACService.test_mem_limit fails with "Invalid 
> or unknown query handle" when canceling a query
> -----------------------------------------------------------------------------------------------------------------------------
>
>                 Key: IMPALA-10596
>                 URL: https://issues.apache.org/jira/browse/IMPALA-10596
>             Project: IMPALA
>          Issue Type: Bug
>    Affects Versions: Impala 4.0
>            Reporter: Andrew Sherman
>            Assignee: Bikramjeet Vig
>            Priority: Critical
>
> TestAdmissionControllerStress.test_mem_limit fails similarly
> {code}
> custom_cluster/test_admission_controller.py:1437: in teardown
>     client.cancel(thread.query_handle)
> common/impala_connection.py:215: in cancel
>     return self.__beeswax_client.cancel_query(operation_handle.get_handle())
> beeswax/impala_beeswax.py:369: in cancel_query
>     return self.__do_rpc(lambda: self.imp_service.Cancel(query_id))
> beeswax/impala_beeswax.py:520: in __do_rpc
>     raise ImpalaBeeswaxException(self.__build_error_message(b), b)
> E   ImpalaBeeswaxException: ImpalaBeeswaxException:
> E    INNER EXCEPTION: <class 'beeswaxd.ttypes.BeeswaxException'>
> E    MESSAGE: Invalid or unknown query handle: 
> 174962332188aac2:1713d0fe00000000.
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-all-unsubscr...@impala.apache.org
For additional commands, e-mail: issues-all-h...@impala.apache.org

Reply via email to