Skip to content

Commit 36771d0

Browse files
authored
remove shardkeyautodisc cal event (#393)
1 parent 4a2d37b commit 36771d0

File tree

1 file changed

+0
-12
lines changed

1 file changed

+0
-12
lines changed

lib/coordinatorsharding.go

-12
Original file line numberDiff line numberDiff line change
@@ -439,18 +439,6 @@ func (crd *Coordinator) PreprocessSharding(requests []*netstring.Netstring) (boo
439439
logmsg += fmt.Sprintf("&sqlhash=%d", sqlhash)
440440
logger.GetLogger().Log(logger.Verbose, logmsg)
441441
}
442-
// restricting cal event to only String type Shard Keys
443-
if GetConfig().ShardKeyValueTypeIsString {
444-
evt := cal.NewCalEvent(EvtTypeSharding, EvtNameShardKeyAutodisc, cal.TransOK, "")
445-
evt.AddDataStr("shardkey", shardkey)
446-
evt.AddDataInt("shardid", shardid)
447-
if len(shardRecs) > 0 {
448-
evt.AddDataInt("scuttleid", int64(shardRecs[0].bin))
449-
evt.AddDataInt("flags", int64(shardRecs[0].flags))
450-
}
451-
evt.AddDataInt("sqlhash", sqlhash)
452-
evt.Completed()
453-
}
454442
}
455443
}
456444

0 commit comments

Comments
 (0)