From 31590bde2c69fb765cdc012bf22294e3edd60ec4 Mon Sep 17 00:00:00 2001 From: Cai Yudong Date: Mon, 27 Sep 2021 11:27:30 +0800 Subject: [PATCH] Rename ChannelID to ShardName to fix build fail (#8646) Signed-off-by: yudong.cai --- internal/msgstream/mq_msgstream_test.go | 2 +- internal/msgstream/repack_func.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/msgstream/mq_msgstream_test.go b/internal/msgstream/mq_msgstream_test.go index a22220a602..024eb3e62b 100644 --- a/internal/msgstream/mq_msgstream_test.go +++ b/internal/msgstream/mq_msgstream_test.go @@ -323,7 +323,7 @@ func TestStream_PulsarMsgStream_DeleteRepackFunc(t *testing.T) { SourceID: 1, }, CollectionName: "Collection", - ChannelID: "1", + ShardName: "chan-1", Timestamp: Timestamp(1), ExprPlan: []byte{}, } diff --git a/internal/msgstream/repack_func.go b/internal/msgstream/repack_func.go index 56a2bf482b..688165d44b 100644 --- a/internal/msgstream/repack_func.go +++ b/internal/msgstream/repack_func.go @@ -102,7 +102,7 @@ func DeleteRepackFunc(tsMsgs []TsMsg, hashKeys [][]int32) (map[int32]*MsgPack, e SourceID: deleteRequest.Base.SourceID, }, CollectionName: deleteRequest.CollectionName, - ChannelID: deleteRequest.ChannelID, + ShardName: deleteRequest.ShardName, Timestamp: deleteRequest.Timestamp, ExprPlan: deleteRequest.ExprPlan, }