fix

Signed-off-by: yisaer <disxiaofei@163.com>
lf-edge · Dec 26, 2023 · 84a1efc · 84a1efc
1 parent f9e20b9
commit 84a1efc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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()