def METHOD_NAME(self, patched_time_sleep):
    error_message = "OutOfMemoryError: null"
    exception = HiveServer2Error(error_message)
    error_handler = ImpalaErrorHandler(logging.getLogger(), num_retries=1)
    (
        mock_native_cursor,
        _,
        _,
        mock_recovery_cursor,
        _,
    ) = populate_mock_managed_cursor(
        mock_exception_to_recover=exception, mock_operation=self._query
    )
    error_handler.handle_error(
        caught_exception=exception, recovery_cursor=mock_recovery_cursor
    )
    mock_native_cursor.execute.assert_called_with(self._query)