From 84a1efc51288e128199a7196020c12db86691e81 Mon Sep 17 00:00:00 2001 From: yisaer Date: Tue, 26 Dec 2023 11:07:02 +0800 Subject: [PATCH] fix Signed-off-by: yisaer --- internal/topo/node/source_pool.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/topo/node/source_pool.go b/internal/topo/node/source_pool.go index ed5128e6ec..d3ec502a0d 100644 --- a/internal/topo/node/source_pool.go +++ b/internal/topo/node/source_pool.go @@ -63,7 +63,7 @@ func getSourceInstance(node *SourceNode, index int) (*sourceInstance, error) { if err != nil { return nil, err } - s.attachSchema(node.ctx.GetRuleId(), node.options.Schema) + //s.attachSchema(node.ctx.GetRuleId(), node.options.Schema) si = &sourceInstance{ source: s.source, ctx: s.ctx, @@ -187,7 +187,7 @@ func (p *sourcePool) deleteInstance(k string, node *SourceNode, index int) { instanceKey := fmt.Sprintf("%s.%s.%d", k, node.ctx.GetRuleId(), index) end := s.detach(instanceKey) - s.detachSchema(s.ctx.GetRuleId()) + //s.detachSchema(s.ctx.GetRuleId()) if end { s.cancel()