We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ec2f4a8 commit 1660894Copy full SHA for 1660894
1 file changed
filebeat/input/filestream/fswatch_test.go
@@ -36,7 +36,6 @@ import (
36
)
37
38
func TestFileWatcher(t *testing.T) {
39
- t.Skip("Flaky test: https://github.com/elastic/beats/issues/41209")
40
dir := t.TempDir()
41
paths := []string{filepath.Join(dir, "*.log")}
42
cfgStr := `
@@ -261,10 +260,10 @@ scanner:
261
260
262
263
scanner:
264
- check_interval: 10ms
+ check_interval: 50ms
265
`
266
267
- ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond)
+ ctx, cancel := context.WithTimeout(context.Background(), 1000*time.Millisecond)
268
defer cancel()
269
270
logp.DevelopmentSetup(logp.ToObserverOutput())
0 commit comments