From 867dd0dda7906cdd9c97e54eaabb4a5a317934df Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 31 May 2018 16:16:03 -0400 Subject: [PATCH] Handle collective.manager being set back to the node --- confluent_server/confluent/consoleserver.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index 792ef4b2..639cf466 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -237,6 +237,8 @@ class ConsoleHandler(object): # Do not do console connect for nodes managed by another # confluent collective member self._is_local = False + else: + self._is_local = True def get_buffer_age(self): """Return age of buffered data