diff --git a/handler/analyzer/analyze_queue.py b/handler/analyzer/analyze_queue.py
index 9a958da8..03b80831 100644
--- a/handler/analyzer/analyze_queue.py
+++ b/handler/analyzer/analyze_queue.py
@@ -111,7 +111,7 @@ def init_option(self):
                 sql = 'select c.tenant_id,GROUP_CONCAT(DISTINCT b.svr_ip ORDER BY b.svr_ip) AS ip_list FROM __all_resource_pool a JOIN __all_unit b ON a.resource_pool_id = b.resource_pool_id JOIN __all_tenant c ON a.tenant_id = c.tenant_id WHERE c.tenant_name ="{0}")'.format(
                     self.tenant
                 )
-            sql_result = self.ob_connector.execute_sql_return_cursor_dictionary(sql).fetchall()
+            sql_result = self.obconn.execute_sql_return_cursor_dictionary(sql).fetchall()
             if len(sql_result) <= 0:
                 self.stdio.exception('Error: tenant is {0} not  in this cluster '.format(tenant_option))
                 return False