From bd5200de5643f16cd9b4001ddb4ad3d43c404d58 Mon Sep 17 00:00:00 2001 From: hanchuanchuan Date: Fri, 26 Jul 2019 15:36:28 +0800 Subject: [PATCH] =?UTF-8?q?update:=20=E4=BC=98=E5=8C=96gh-ost=E7=9A=84serv?= =?UTF-8?q?er=5Fid=E6=A0=B9=E6=8D=AE=E4=BC=9A=E8=AF=9DID=E8=87=AA=E5=8A=A8?= =?UTF-8?q?=E5=8F=98=E5=8C=96,=E9=81=BF=E5=85=8D=E5=90=8C=E4=B8=80?= =?UTF-8?q?=E5=AE=9E=E4=BE=8B=E9=87=8D=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- session/osc.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/session/osc.go b/session/osc.go index 9634a095..7fd39280 100644 --- a/session/osc.go +++ b/session/osc.go @@ -328,7 +328,7 @@ func (s *session) mysqlExecuteAlterTableGhost(r *Record) { // flag.StringVar(&migrationContext.HooksHintOwner, "hooks-hint-owner", "", "arbitrary name of owner to be injected to hooks via GH_OST_HOOKS_HINT_OWNER, for your convenience") // flag.StringVar(&migrationContext.HooksHintToken, "hooks-hint-token", "", "arbitrary token to be injected to hooks via GH_OST_HOOKS_HINT_TOKEN, for your convenience") - migrationContext.ReplicaServerId = 99999 + migrationContext.ReplicaServerId = 2000100000 + uint(s.sessionVars.ConnectionID%10000) // flag.UintVar(&migrationContext.ReplicaServerId, "replica-server-id", 99999, "server id used by gh-ost process. Default: 99999") // maxLoad := s.Ghost.GhostMaxLoad // maxLoad := flag.String("max-load", "", "Comma delimited status-name=threshold. e.g: 'Threads_running=100,Threads_connected=500'. When status exceeds threshold, app throttles writes") @@ -556,6 +556,7 @@ func (s *session) mysqlExecuteAlterTableGhost(r *Record) { log.Error(err) done = true s.AppendErrorMessage(err.Error()) + // migrator.Teardown() } done = true