diff --git a/pkg/elasticsearch/read.go b/pkg/elasticsearch/read.go index 9ef45e8..0f2fa31 100644 --- a/pkg/elasticsearch/read.go +++ b/pkg/elasticsearch/read.go @@ -24,8 +24,6 @@ func (c *Client) Read(process engine.ProcessQuery, writer engine.Target, progres query = process.ReadQuery ) - log.Info(strings.NewReader(query.Query)) - for { batchNum++