restrict shard_key_auto_discovery event to str shard keys

paypal · Dec 14, 2023 · e3f2fc3 · e3f2fc3
1 parent cc560d4
commit e3f2fc3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/coordinatorsharding.go b/lib/coordinatorsharding.go
@@ -425,8 +425,9 @@ func (crd *Coordinator) PreprocessSharding(requests []*netstring.Netstring) (boo
 			logger.GetLogger().Log(logger.Verbose, fmt.Sprintf("shard info auto discovery: key_name=%s, num_values=%d", GetConfig().ShardKeyName, len(crd.shard.shardValues)))
 		}
 
-		if len(crd.shard.shardValues) > 0 {
+		if (len(crd.shard.shardValues) > 0) && GetConfig().ShardKeyValueTypeIsString {
 			// shard_key_auto_discovery
+			// restricting this event to only String type Shard Keys
 			evt := cal.NewCalEvent(EvtTypeSharding, EvtNameShardKeyAutodisc, cal.TransOK, "")
 			evt.AddDataStr("shardkey", GetConfig().ShardKeyName+"|"+crd.shard.shardValues[0])
 			evt.AddDataInt("shardid", int64(crd.shard.shardID))