address comments

service/history/historyEngineInterfaces.go

@@ -141,6 +141,10 @@ type (
 	}
 )
 
+var (
+	standbyTaskRetryError = newTaskRetryError()
+)
+
 // newTaskRetryError create a error which indicate the task should be retry
 func newTaskRetryError() *taskRetryError {
 	return &taskRetryError{}

service/history/timerQueueAckMgr.go

@@ -170,7 +170,6 @@ func (t *timerQueueAckMgrImpl) readTimerTasks() ([]*persistence.TimerTaskInfo, *
 		t.isReadFinished = true
 	}
 
-	// fillin the retry task
 	filteredTasks := []*persistence.TimerTaskInfo{}
 
 	// since we have already checked that the clusterName is a valid key of clusterReadLevel

service/history/timerQueueStandbyProcessor.go

@@ -197,7 +197,7 @@ func (t *timerQueueStandbyProcessorImpl) processExpiredUserTimer(timerTask *pers
 				//
 				// we do not need to notity new timer to base, since if there is no new event being replicated
 				// checking again if the timer can be completed is meaningless
-				return newTaskRetryError()
+				return standbyTaskRetryError
 			}
 			// since the user timer are already sorted, so if there is one timer which will not expired
 			// all user timer after this timer will not expired
@@ -237,7 +237,7 @@ func (t *timerQueueStandbyProcessorImpl) processActivityTimeout(timerTask *persi
 				//
 				// we do not need to notity new timer to base, since if there is no new event being replicated
 				// checking again if the timer can be completed is meaningless
-				return newTaskRetryError()
+				return standbyTaskRetryError
 			}
 			// since the activity timer are already sorted, so if there is one timer which will not expired
 			// all activity timer after this timer will not expired
@@ -262,7 +262,7 @@ func (t *timerQueueStandbyProcessorImpl) processDecisionTimeout(timerTask *persi
 			//
 			// we do not need to notity new timer to base, since if there is no new event being replicated
 			// checking again if the timer can be completed is meaningless
-			return newTaskRetryError()
+			return standbyTaskRetryError
 		}
 		return nil
 	})
@@ -276,7 +276,7 @@ func (t *timerQueueStandbyProcessorImpl) processWorkflowTimeout(timerTask *persi
 	return t.processTimer(timerTask, func(msBuilder *mutableStateBuilder) error {
 		// we do not need to notity new timer to base, since if there is no new event being replicated
 		// checking again if the timer can be completed is meaningless
-		return newTaskRetryError()
+		return standbyTaskRetryError
 	})
 }