bugfix: remove debug log

alibaba · Apr 24, 2024 · f4f6d23 · f4f6d23
1 parent cd2aa1f
commit f4f6d23
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 19 deletions.
diff --git a/internal/actor/container_actor.go b/internal/actor/container_actor.go
@@ -59,12 +59,6 @@ type containerActor struct {
 	lock                      sync.Mutex
 }
 
-// 声明并初始化两个计数器变量
-var (
-	startCounter int
-	stopCounter  int
-)
-
 func newContainerActor() *containerActor {
 	return &containerActor{
 		enableShareContainerPool:  config.GetWorkerConfig().IsShareContainerPool(),
@@ -218,8 +212,6 @@ func (a *containerActor) handleDestroyContainerPool(actorCtx actor.Context, req
 		logger.Infof("handleDestroyContainerPool from jobInstanceId=%v.", req.GetJobInstanceId())
 		a.statusReqBatchHandlerPool.Stop(req.GetJobInstanceId())
 		a.containerPool.DestroyByInstance(req.GetJobInstanceId())
-		stopCounter++
-		logger.Infof("======container_actor.stopCounter=%d\n", stopCounter)
 		/*
 			if h, ok := handler.(*batch.ContainerStatusReqHandler); ok {
 
@@ -302,8 +294,6 @@ func (a *containerActor) startContainer(actorCtx actor.Context, req *schedulerx.
 				batch.NewContainerStatusReqHandler(statusReqBatchHandlerKey, 1, 1,
 					a.batchSize, reqQueue, req.GetInstanceMasterAkkaPath()),
 			)
-			startCounter++
-			logger.Infof("======container_actor.startCounter=%d\n", startCounter)
 		}
 		consumerNum := int32(constants.ConsumerNumDefault)
 		if req.GetConsumerNum() > 0 {

diff --git a/internal/master/standalone_task_master.go b/internal/master/standalone_task_master.go
@@ -50,11 +50,6 @@ type StandaloneTaskMaster struct {
 	taskMasterPoolCleaner func(int64)
 }
 
-var (
-	startCounter int
-	stopCounter  int
-)
-
 func NewStandaloneTaskMaster(jobInstanceInfo *common.JobInstanceInfo, actorCtx actor.Context) taskmaster.TaskMaster {
 	var (
 		connpool              = pool.GetConnPool()
@@ -136,14 +131,12 @@ func (m *StandaloneTaskMaster) SubmitInstance(ctx context.Context, jobInstanceIn
 	resp, ok := response.(*schedulerx.MasterStartContainerResponse)
 	if !ok {
 		m.taskStatusMap.Store(uniqueId, taskstatus.TaskStatusFailed)
-		logger.Infof("======standalone_task_master.startCounter=%d\n", startCounter)
 		err = fmt.Errorf("response is not MasterStartContainerResponse, resp=%+v", response)
 		return err
 	}
 	if resp.GetSuccess() {
 		m.taskStatusMap.Store(uniqueId, taskstatus.TaskStatusInit)
 		logger.Infof("Standalone taskMaster init worker succeed, workerAddr=%s, uniqueId=%s", workerAddr, uniqueId)
-		startCounter++
 		return nil
 	}
 
@@ -207,8 +200,6 @@ func (m *StandaloneTaskMaster) DestroyContainerPool() {
 	if err := m.actorContext.RequestFuture(actorcomm.GetContainerRouterPid(m.currentSelection), req, 5*time.Second).Wait(); err != nil {
 		logger.Errorf("Destroy containerPool failed, err: %s", err.Error())
 	}
-	stopCounter++
-	logger.Infof("======standalone_task_master.stopCounter=%d\n", stopCounter)
 }
 
 func (m *StandaloneTaskMaster) CheckProcessor() error {