livetail timestamp correction

bmike78 · Jul 22, 2022 · f8be4a6 · f8be4a6
1 parent 420d46a
commit f8be4a6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/query-service/app/clickhouseReader/reader.go b/pkg/query-service/app/clickhouseReader/reader.go
@@ -2908,7 +2908,7 @@ func (r *ClickHouseReader) TailLogs(ctx context.Context, client *model.LogsTailC
 		"CAST((resources_string_key, resources_string_value), 'Map(String, String)') as resources_string "+
 		"from %s.%s", r.logsDB, r.logsTable)
 
-	tsStart := uint64(time.Now().UnixNano() / int64(time.Millisecond))
+	tsStart := uint64(time.Now().UnixNano())
 	if client.Filter.TimestampStart != nil {
 		tsStart = *client.Filter.TimestampStart
 	}
@@ -2959,7 +2959,7 @@ func (r *ClickHouseReader) TailLogs(ctx context.Context, client *model.LogsTailC
 				}
 			}
 			if len == 0 {
-				tsStart = uint64(time.Now().UnixNano() / int64(time.Millisecond))
+				tsStart = uint64(time.Now().UnixNano())
 			}
 			time.Sleep(2 * time.Second)
 		}