Fix insertion miss

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2020-09-27 11:55:14 +08:00 · 2020-09-27 11:55:14 +08:00 · a84bafd1fb
parent 5e429b2a94
commit a84bafd1fb
1 changed files with 1 additions and 5 deletions
--- a/reader/message_client/message_client.go
+++ b/reader/message_client/message_client.go
@ -42,11 +42,7 @@ type MessageClient struct {
 }

 func (mc *MessageClient) GetTimeNow() uint64 {
-	msg, ok := <-mc.timeSyncCfg.TimeSync()
-	if !ok {
-		fmt.Println("cnn't get data from timesync chan")
-	}
-	return msg.Timestamp
+	return mc.timestampBatchEnd
 }

 func (mc *MessageClient) TimeSyncStart() uint64 {