From 6d51b2e3f470ec80e89d95dfa5e86d7d31a418e1 Mon Sep 17 00:00:00 2001 From: SimFG Date: Fri, 25 Oct 2024 10:00:01 +0800 Subject: [PATCH] remove the invalid log (#149) Signed-off-by: SimFG --- core/reader/replicate_channel_manager.go | 8 -------- 1 file changed, 8 deletions(-) diff --git a/core/reader/replicate_channel_manager.go b/core/reader/replicate_channel_manager.go index 30e65db..7a22844 100644 --- a/core/reader/replicate_channel_manager.go +++ b/core/reader/replicate_channel_manager.go @@ -1182,10 +1182,6 @@ func (r *replicateChannelHandler) startReadChannel() { if r.sourceSeekPosition != nil { cts = r.sourceSeekPosition.GetTimestamp() } - log.Info("start read channel in the handler before", - zap.String("channel_name", r.sourcePChannel), - zap.String("target_channel", r.targetPChannel), - ) GetTSManager().InitTSInfo(r.replicateID, r.targetPChannel, time.Duration(r.handlerOpts.TTInterval)*time.Millisecond, cts, r.handlerOpts.MessageBufferSize) log.Info("start read channel in the handler", zap.String("channel_name", r.sourcePChannel), @@ -1193,10 +1189,6 @@ func (r *replicateChannelHandler) startReadChannel() { ) close(r.startReadChan) r.collectionSourceSeekPosition(r.sourceSeekPosition) - log.Info("start read channel in the handler end", - zap.String("channel_name", r.sourcePChannel), - zap.String("target_channel", r.targetPChannel), - ) go func() { for { select {