From 02f1515420cc5df9fc6c74621b5b1a419a17ebcc Mon Sep 17 00:00:00 2001
From: yfh <yuan.fenghua@free-sun.com.cn>
Date: Tue, 12 Nov 2024 15:18:06 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=B3=E9=97=AD=E6=8E=A8=E9=80=81=E5=8A=9F?=
=?UTF-8?q?=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
node/app/app.go | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/node/app/app.go b/node/app/app.go
index b02c884..3614187 100644
--- a/node/app/app.go
+++ b/node/app/app.go
@@ -8,7 +8,6 @@ import (
"et_calc"
"et_calc/group"
"et_print"
- "et_push"
"et_sink"
"fmt"
"gitea.anxinyun.cn/container/common_utils/configLoad"
@@ -107,8 +106,8 @@ func addWorkStages(nodeStageManage *stages.StageManager) *stages.StageManager {
nodeStageManage.AddStages(stationAnalyzeHandler.GetStage())
// 数据推送
- publishHandler := et_push.NewPushHandler()
- nodeStageManage.AddStages(publishHandler.GetStage())
+ //publishHandler := et_push.NewPushHandler()
+ //nodeStageManage.AddStages(publishHandler.GetStage())
return nodeStageManage
}