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 }