Issue can be recreated if security group id is explicitly assigned and schema is restarted.
I patched the setup to convert the security-group id to int() before calling zk api.
def set_configured_security_group_id(self, config_id): if self.config_sgid == config_id: return self.config_sgid = config_id sg_id = self.obj.get_security_group_id() if config_id: if sg_id is not None: if int(sg_id) > SGID_MIN_ALLOC: self._sg_id_allocator.delete(int(sg_id) - SGID_MIN_ALLOC) <<< else: if self.name == self._sg_id_allocator.read(int(sg_id)): <<< self._sg_id_allocator.delete(int(sg_id)) <<< self.obj.set_security_group_id(str(config_id)) else:
Issue can be recreated if security group id is explicitly assigned and schema is restarted.
I patched the setup to convert the security-group id to int() before calling zk api.
def set_configured_ security_ group_id( self, config_id):
self.config_ sgid = config_id get_security_ group_id( )
self. _sg_id_ allocator. delete( int(sg_ id) - SGID_MIN_ALLOC) <<<
else:
if self.name == self._sg_ id_allocator. read(int( sg_id)) : <<<
self. _sg_id_ allocator. delete( int(sg_ id)) <<<
self. obj.set_ security_ group_id( str(config_ id))
if self.config_sgid == config_id:
return
sg_id = self.obj.
if config_id:
if sg_id is not None:
if int(sg_id) > SGID_MIN_ALLOC:
else: