From a84bafd1fb257b1c5ad957d3a4fb4f7ed9e89a70 Mon Sep 17 00:00:00 2001
From: bigsheeper <yihao.dai@zilliz.com>
Date: Sun, 27 Sep 2020 11:55:14 +0800
Subject: [PATCH] Fix insertion miss

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
---
 reader/message_client/message_client.go | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/reader/message_client/message_client.go b/reader/message_client/message_client.go
index 71e8bcf261..7a2a9add89 100644
--- 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 {