Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 3 additions & 4 deletions filebeat/input/filestream/fswatch.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,14 +23,15 @@ import (
"path/filepath"
"time"

"github.com/elastic/go-concert/timed"
"github.com/elastic/go-concert/unison"

"github.com/elastic/beats/v7/filebeat/input/file"
loginp "github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile"
"github.com/elastic/beats/v7/libbeat/common"
file_helper "github.com/elastic/beats/v7/libbeat/common/file"
"github.com/elastic/beats/v7/libbeat/common/match"
"github.com/elastic/beats/v7/libbeat/logp"
"github.com/elastic/go-concert/timed"
"github.com/elastic/go-concert/unison"
)

const (
Expand Down Expand Up @@ -133,8 +134,6 @@ func (w *fileWatcher) Run(ctx unison.Canceler) {
}

func (w *fileWatcher) watch(ctx unison.Canceler) {
w.log.Info("Start next scan")

paths := w.scanner.GetFiles()
Comment thread
cmacknz marked this conversation as resolved.

newFiles := make(map[string]os.FileInfo)
Expand Down