=== RUN   TestFilestreamTruncateBlockedOutput
coverage: 66.3% of statements
panic: test timed out after 10m0s

goroutine 370 [running]:
testing.(*M).startAlarm.func1()
	/usr/local/go/src/testing/testing.go:1700 +0xe5
created by time.goFunc
	/usr/local/go/src/time/sleep.go:180 +0x45

goroutine 1 [chan receive, 9 minutes]:
testing.(*T).Run(0xc0002d2600, 0xcfc5a0, 0x23, 0xd1a9c8, 0x493d01)
	/usr/local/go/src/testing/testing.go:1239 +0x2da
testing.runTests.func1(0xc000582780)
	/usr/local/go/src/testing/testing.go:1511 +0x78
testing.tRunner(0xc000582780, 0xc0006bfda8)
	/usr/local/go/src/testing/testing.go:1193 +0xef
testing.runTests(0xc0004b0a38, 0x12f81e0, 0x32, 0x32, 0xc03837aaeb1cf1ce, 0x8bb582a7c8, 0x131a720, 0xceb088)
	/usr/local/go/src/testing/testing.go:1509 +0x2fe
testing.(*M).Run(0xc0004be380, 0x0)
	/usr/local/go/src/testing/testing.go:1417 +0x1eb
main.main()
	_testmain.go:207 +0x1c5

goroutine 326 [runnable]:
github.com/elastic/go-structform/gotype.foldInterfaceValue(0xc000248360, 0xbe62c0, 0xc00019cea0, 0x0, 0x0)
	/go/pkg/mod/github.com/elastic/go-structform@v0.0.9/gotype/fold.go:96 +0x47d
github.com/elastic/go-structform/gotype.foldMapInterface(0xc000248360, 0xbe62c0, 0xc00019cde0, 0x134ab40, 0xb878a0)
	/go/pkg/mod/github.com/elastic/go-structform@v0.0.9/gotype/fold_map.go:55 +0x179
github.com/elastic/go-structform/gotype.foldInterfaceValue(0xc000248360, 0xbe62c0, 0xc00019cde0, 0x0, 0x0)
	/go/pkg/mod/github.com/elastic/go-structform@v0.0.9/gotype/fold.go:105 +0x445
github.com/elastic/go-structform/gotype.(*Iterator).Fold(...)
	/go/pkg/mod/github.com/elastic/go-structform@v0.0.9/gotype/fold.go:93
github.com/elastic/beats/v7/libbeat/common/transform/typeconv.(*Converter).Convert(0xc000600010, 0xb878a0, 0xc0005d4738, 0xbe62c0, 0xc00019cde0, 0x0, 0x0)
	/go/src/github.com/elastic/beats/libbeat/common/transform/typeconv/typeconv.go:108 +0x136
github.com/elastic/beats/v7/libbeat/common/transform/typeconv.Convert(0xb878a0, 0xc0005d4738, 0xbe62c0, 0xc00019cde0, 0x0, 0x0)
	/go/src/github.com/elastic/beats/libbeat/common/transform/typeconv/typeconv.go:129 +0xc7
github.com/elastic/beats/v7/libbeat/statestore/storetest.(*MapStore).Get(0xc000450d50, 0xc000774570, 0x28, 0xb878a0, 0xc0005d4738, 0x0, 0x0)
	/go/src/github.com/elastic/beats/libbeat/statestore/storetest/storetest.go:156 +0xe5
github.com/elastic/beats/v7/libbeat/statestore.(*Store).Get(0xc0002ab700, 0xc000774570, 0x28, 0xb878a0, 0xc0005d4738, 0x0, 0x0)
	/go/src/github.com/elastic/beats/libbeat/statestore/store.go:101 +0x13c
github.com/elastic/beats/v7/filebeat/input/filestream.(*inputTestingEnvironment).getRegistryState(0xc0004b43c0, 0xc000774570, 0x28, 0x17, 0xbe62c0, 0xc0002a7230, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/environment_test.go:275 +0x98
github.com/elastic/beats/v7/filebeat/input/filestream.(*inputTestingEnvironment).waitUntilOffsetInRegistry(0xc0004b43c0, 0xce70fc, 0x8, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/environment_test.go:238 +0x1fe
github.com/elastic/beats/v7/filebeat/input/filestream.TestFilestreamTruncateBlockedOutput(0xc0002d2600)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/input_integration_test.go:726 +0x545
testing.tRunner(0xc0002d2600, 0xd1a9c8)
	/usr/local/go/src/testing/testing.go:1193 +0xef
created by testing.(*T).Run
	/usr/local/go/src/testing/testing.go:1238 +0x2b3

goroutine 247 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000165830, 0xddacf8, 0xc0006ffec0, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc000126dc0, 0xddacf8, 0xc0006ffec0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0006ffec0, 0xc0006ffec0, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc000126dc8, 0xc000166500)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 221 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc00015d920, 0xddacf8, 0xc0006ff940, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc000126c80, 0xddacf8, 0xc0006ff940)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0006ff940, 0xc0006ff940, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc000126c88, 0xc000155380)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 88 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc0004509c0, 0xddacf8, 0xc000394300, 0x2, 0x2, 0x2, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc000126500, 0xddacf8, 0xc000394300)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000394300, 0xc000394300, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc000126508, 0xc0000729c0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 89 [semacquire, 9 minutes]:
sync.runtime_Semacquire(0xc000451b58)
	/usr/local/go/src/runtime/sema.go:56 +0x45
sync.(*WaitGroup).Wait(0xc000451b50)
	/usr/local/go/src/sync/waitgroup.go:130 +0x65
github.com/elastic/go-concert/unison.(*MultiErrGroup).Wait(0xc000451b30, 0x0, 0x0, 0x0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:54 +0x53
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileProspector).Run(0xc0003f4140, 0xc000073020, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/prospector.go:137 +0x3a5
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*managedInput).Run(0xc0001f0a80, 0xc000073020, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/input.go:80 +0x3ab
github.com/elastic/beats/v7/filebeat/input/filestream.(*inputTestingEnvironment).startInput.func1(0xddacf8, 0xc0003944c0, 0xdd86e0, 0xc0001f0a80, 0xc0001263c0, 0xc000126450)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/environment_test.go:95 +0x14c
created by github.com/elastic/beats/v7/filebeat/input/filestream.(*inputTestingEnvironment).startInput
	/go/src/github.com/elastic/beats/filebeat/input/filestream/environment_test.go:91 +0x9a

goroutine 90 [select]:
github.com/elastic/go-concert/timed.Periodic(0x7fa184fd4480, 0xc000394500, 0x989680, 0xc0006d5ec0, 0x0, 0x0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/timed/timed.go:76 +0x118
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileWatcher).Run(0xc000394480, 0x7fa184fd4458, 0xc000394500)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/fswatch.go:129 +0x10b
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileProspector).Run.func1(0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/prospector.go:117 +0x9a
github.com/elastic/go-concert/unison.(*MultiErrGroup).Go.func1(0xc000451b30, 0xc00000e8a0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:42 +0x64
created by github.com/elastic/go-concert/unison.(*MultiErrGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:40 +0x66

goroutine 91 [chan receive, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileWatcher).Event(0xc000394480, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/fswatch.go:229 +0x85
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileProspector).Run.func2(0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/prospector.go:125 +0x450
github.com/elastic/go-concert/unison.(*MultiErrGroup).Go.func1(0xc000451b30, 0xc000394540)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:42 +0x64
created by github.com/elastic/go-concert/unison.(*MultiErrGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:40 +0x66

goroutine 211 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc00014f050, 0xddacf8, 0xc0006ff3c0, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc000126b40, 0xddacf8, 0xc0006ff3c0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0006ff3c0, 0xc0006ff3c0, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc000126b48, 0xc0001541d0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 130 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc0006f6a80, 0xddacf8, 0xc0006fe280, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0004b4780, 0xddacf8, 0xc0006fe280)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0006fe280, 0xc0006fe280, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0004b4788, 0xc000293b50)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 148 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000248ab0, 0xddacf8, 0xc000042500, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0000c8320, 0xddacf8, 0xc000042500)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000042500, 0xc000042500, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0000c8328, 0xc000238ac0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 155 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000262120, 0xddacf8, 0xc000042d80, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0000c85a0, 0xddacf8, 0xc000042d80)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000042d80, 0xc000042d80, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0000c85a8, 0xc000239aa0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 160 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000262c00, 0xddacf8, 0xc000042300, 0x40d8ca, 0xc0f4e0, 0xc3bc80, 0x40c401, 0xddacf8)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0004b5360, 0xddacf8, 0xc000042300)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000042300, 0xc000042300, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0004b5368, 0xc000073230)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 172 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000450960, 0xddacf8, 0xc000394200, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0000c86e0, 0xddacf8, 0xc000394200)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000394200, 0xc000394200, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0000c86e8, 0xc000292270)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 197 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000248150, 0xddacf8, 0xc0006feb00, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc000126a00, 0xddacf8, 0xc0006feb00)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0006feb00, 0xc0006feb00, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc000126a08, 0xc00016b630)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 41 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc00059b980, 0xddacf8, 0xc0004bb040, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0007560a0, 0xddacf8, 0xc0004bb040)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0004bb040, 0xc0004bb040, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0007560a8, 0xc0005c4500)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 338 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc00014e8a0, 0xddacf8, 0xc0002d6680, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc000756140, 0xddacf8, 0xc0002d6680)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0002d6680, 0xc0002d6680, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc000756148, 0xc000293330)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 183 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc00049fad0, 0xddacf8, 0xc000394f00, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0000c8960, 0xddacf8, 0xc000394f00)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000394f00, 0xc000394f00, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0000c8968, 0xc000293560)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 137 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000143080, 0xddacf8, 0xc0006fe1c0, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0001268c0, 0xddacf8, 0xc0006fe1c0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0006fe1c0, 0xc0006fe1c0, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0001268c8, 0xc00016a2e0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 274 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000249320, 0xddacf8, 0xc000042380, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0004b54a0, 0xddacf8, 0xc000042380)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000042380, 0xc000042380, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0004b54a8, 0xc000166d10)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 260 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc00019d860, 0xddacf8, 0xc000395b00, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0000c8be0, 0xddacf8, 0xc000395b00)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000395b00, 0xc000395b00, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0000c8be8, 0xc00014cb00)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 314 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000776180, 0xddacf8, 0xc0002d6400, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc000756280, 0xddacf8, 0xc0002d6400)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0002d6400, 0xc0002d6400, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc000756288, 0xc000238490)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 332 [select]:
github.com/elastic/go-concert/timed.Periodic(0x7fa184fd4480, 0xc0006ff500, 0xf4240, 0xc0006d1ec0, 0x0, 0x0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/timed/timed.go:76 +0x118
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileWatcher).Run(0xc0006ff480, 0x7fa184fd4458, 0xc0006ff500)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/fswatch.go:129 +0x10b
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileProspector).Run.func1(0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/prospector.go:117 +0x9a
github.com/elastic/go-concert/unison.(*MultiErrGroup).Go.func1(0xc00049e120, 0xc0005d4408)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:42 +0x64
created by github.com/elastic/go-concert/unison.(*MultiErrGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:40 +0x66

goroutine 272 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000608f00, 0xddacf8, 0xc000216480, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0004b5900, 0xddacf8, 0xc000216480)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc000216480, 0xc000216480, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0004b5908, 0xc00016a820)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 320 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000777a70, 0xddacf8, 0xc0002d6a40, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0007563c0, 0xddacf8, 0xc0002d6a40)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0002d6a40, 0xc0002d6a40, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0007563c8, 0xc0002396f0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 330 [select, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateChan).Recv(0xc000450f30, 0xddacf8, 0xc0006ff300, 0x1, 0x1, 0x1, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:146 +0x158
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*updateWriter).run(0xc0004b57c0, 0xddacf8, 0xc0006ff300)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:82 +0x8b
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.newUpdateWriter.func1(0x7fa184fd4458, 0xc0006ff300, 0xc0006ff300, 0x7fa184fd4458)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/update_writer.go:66 +0xa5
github.com/elastic/go-concert/unison.(*TaskGroup).Go.func1(0xc0004b57c8, 0xc0004abe50)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:124 +0x99
created by github.com/elastic/go-concert/unison.(*TaskGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/taskgroup.go:122 +0xda

goroutine 333 [chan receive, 9 minutes]:
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileWatcher).Event(0xc0006ff480, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/fswatch.go:229 +0x85
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileProspector).Run.func2(0x0, 0x0)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/prospector.go:125 +0x450
github.com/elastic/go-concert/unison.(*MultiErrGroup).Go.func1(0xc00049e120, 0xc0006ff540)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:42 +0x64
created by github.com/elastic/go-concert/unison.(*MultiErrGroup).Go
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:40 +0x66

goroutine 331 [semacquire, 9 minutes]:
sync.runtime_Semacquire(0xc00049e148)
	/usr/local/go/src/runtime/sema.go:56 +0x45
sync.(*WaitGroup).Wait(0xc00049e140)
	/usr/local/go/src/sync/waitgroup.go:130 +0x65
github.com/elastic/go-concert/unison.(*MultiErrGroup).Wait(0xc00049e120, 0x0, 0x0, 0x0)
	/go/pkg/mod/github.com/elastic/go-concert@v0.1.0/unison/multierrgroup.go:54 +0x53
github.com/elastic/beats/v7/filebeat/input/filestream.(*fileProspector).Run(0xc000032460, 0xc000073020, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/prospector.go:137 +0x3a5
github.com/elastic/beats/v7/filebeat/input/filestream/internal/input-logfile.(*managedInput).Run(0xc0006bb320, 0xc000073020, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, ...)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/internal/input-logfile/input.go:80 +0x3ab
github.com/elastic/beats/v7/filebeat/input/filestream.(*inputTestingEnvironment).startInput.func1(0xddacf8, 0xc0006ff4c0, 0xdd86e0, 0xc0006bb320, 0xc0004b43c0, 0xc0004b4450)
	/go/src/github.com/elastic/beats/filebeat/input/filestream/environment_test.go:95 +0x14c
created by github.com/elastic/beats/v7/filebeat/input/filestream.(*inputTestingEnvironment).startInput
	/go/src/github.com/elastic/beats/filebeat/input/filestream/environment_test.go:91 +0x9a```