Skip to content

Commit c39af45

Browse files
committed
fix: 北极星频繁切换leader导致服务注册一直失败超时
1 parent 64fee5c commit c39af45

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

store/mysql/admin.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,8 @@ func (l *leaderElectionStore) CompareAndSwapVersion(key string, curVersion int64
134134
// CheckMtimeExpired check last modify time expired
135135
func (l *leaderElectionStore) CheckMtimeExpired(key string, leaseTime int32) (string, bool, error) {
136136
log.Debugf("[Store][database] check mtime expired (%s, %d)", key, leaseTime)
137-
mainStr := "select leader, FROM_UNIXTIME(UNIX_TIMESTAMP(SYSDATE())) - mtime from leader_election where elect_key = ?"
137+
mainStr := `select leader, UNIX_TIMESTAMP(SYSDATE()) - UNIX_TIMESTAMP(mtime)
138+
from leader_election where elect_key = ?`
138139

139140
var (
140141
leader string

0 commit comments

Comments
 (0)