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()