typelevel / typelevel/fs2

evalFilterNotAsync test flaky

Open
#3,133 0 comments 0 reactions 0 assignees View on GitHub

Nobody has claimed this yet.

bug
Dominant language
Scala
Stars
2.5k
Forks
636
Avg merge
2d 4h
Merged PRs (30d)
7

Description

==> X fs2.StreamCombinatorsSuite.evalFilterNotAsync - filters up to N items in parallel  2.02s java.util.NoSuchElementException: null
[1133](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1134)
    at fs2.Stream$CompileOps.lastOrError$$anonfun$1$$anonfun$1(Stream.scala:4875)
[1134](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1135)
    at scala.Option.fold(Option.scala:263)
[1135](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1136)
    at fs2.Stream$CompileOps.lastOrError$$anonfun$1(Stream.scala:4875)
[1136](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1137)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1137](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1138)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1138](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1139)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1139](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1140)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1140](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1141)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1141](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1142)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1142](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1143)
    at modify @ fs2.internal.Scope.close(Scope.scala:262)
[1143](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1144)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1144](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1145)
    at rethrow$extension @ fs2.Compiler$Target.compile$$anonfun$1(Compiler.scala:157)
[1145](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1146)
    at get @ fs2.internal.Scope.openScope(Scope.scala:281)
[1146](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1147)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1147](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1148)
    at flatMap @ fs2.Pull$.goCloseScope$1$$anonfun$1$$anonfun$3(Pull.scala:1216)
[1148](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1149)
    at update @ fs2.internal.Scope.releaseChildScope(Scope.scala:227)
[1149](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1150)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)
[1150](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1151)
    at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163)

Contributor guide

Open the contributing guide

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

Research direction

Start by reproducing fs2.StreamCombinatorsSuite.evalFilterNotAsync and inspect the reported NoSuchElementException at Stream.scala:4875, using the linked CI failure for context. The work is done when the test no longer flakes across repeated runs and continues to verify filtering up to N items in parallel.

Written by the indexing model from the issue text.

Assessment

Tech stack
scala
Domain
stream-processing, testing
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.