diff --git a/master/metadata_fsm.go b/master/metadata_fsm.go index 0feb941dd..2ae6c2282 100644 --- a/master/metadata_fsm.go +++ b/master/metadata_fsm.go @@ -110,13 +110,14 @@ func (mf *MetadataFsm) Apply(command []byte, index uint64) (resp interface{}, er mf.raftLk.Lock() defer mf.raftLk.Unlock() - log.LogDebugf("action[Apply] apply index(%v)", index) cmd := new(RaftCmd) if err = cmd.Unmarshal(command); err != nil { log.LogErrorf("action[fsmApply],unmarshal data:%v, err:%v", command, err.Error()) panic(err) } + log.LogDebugf("action[Apply] apply index(%v), op %d", index, cmd.Op) + if cmd.Op == opSyncUpdateDataPartition || cmd.Op == opSyncDeleteDataPartition { dpv := &dataPartitionValue{} if err := json.Unmarshal(cmd.V, dpv); err != nil { diff --git a/sdk/meta/conn.go b/sdk/meta/conn.go index 431c6f8a6..8e6bad734 100644 --- a/sdk/meta/conn.go +++ b/sdk/meta/conn.go @@ -120,6 +120,8 @@ sendWithList: log.LogWarnf("sendToMetaPartition: leader failed and goto retry, req(%v) mp(%v) mc(%v) err(%v) resp(%v)", req, mp, mc, err, resp) goto sendWithList } + log.LogWarnf("sendToMetaPartition: leader failed and goto retry, req(%v) mp(%v) mc(%v) err(%v), addr(%s)", + req, mp, mc, err, addr) mw.putConn(mc, err) retry: start = time.Now()