add some logs to help debug

Signed-off-by: yibin87 <[email protected]>
pingcap · Jan 13, 2025 · 94d41eb · 94d41eb
1 parent 717da62
commit 94d41eb
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/executor/internal/mpp/local_mpp_coordinator.go b/pkg/executor/internal/mpp/local_mpp_coordinator.go
@@ -398,6 +398,7 @@ func (c *localMppCoordinator) fillSameZoneFlagForExchange(exec *tipb.Executor, t
 			receiverZone, receiverExist := zoneMap[taskMeta.GetAddress()]
 			sameZoneFlags = append(sameZoneFlags, !receiverExist || taskZoneLabel == receiverZone)
 		}
+		logutil.BgLogger().Warn(fmt.Sprintf("unknown new tipb protocol %v %v", exec.ExecutorId, sameZoneFlags))
 		exec.ExchangeSender.SameZoneFlag = sameZoneFlags
 	case tipb.ExecType_TypeExchangeReceiver:
 		sameZoneFlags := make([]bool, 0, len(exec.ExchangeReceiver.EncodedTaskMeta))
@@ -418,6 +419,7 @@ func (c *localMppCoordinator) fillSameZoneFlagForExchange(exec *tipb.Executor, t
 			senderZone, senderExist := zoneMap[taskMeta.GetAddress()]
 			sameZoneFlags = append(sameZoneFlags, !senderExist || taskZoneLabel == senderZone)
 		}
+		logutil.BgLogger().Warn(fmt.Sprintf("unknown new tipb protocol %v %v", exec.ExecutorId, sameZoneFlags))
 		exec.ExchangeReceiver.SameZoneFlag = sameZoneFlags
 	case tipb.ExecType_TypeJoin:
 		children = append(children, exec.Join.Children...)