Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-25903

Flaky test: BarrierTaskContextSuite.throw exception on barrier() call timeout

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.4.0, 3.0.0
    • 2.4.5, 3.0.0
    • Tests
    • None

    Description

      We hit this in our internal builds.

      Expected exception org.apache.spark.SparkException to be thrown, but no exception was thrown
      Stacktrace
            org.scalatest.exceptions.TestFailedException: Expected exception org.apache.spark.SparkException to be thrown, but no exception was thrown
            at org.scalatest.Assertions$class.newAssertionFailedException(Assertions.scala:528)
            at org.scalatest.FunSuite.newAssertionFailedException(FunSuite.scala:1560)
            at org.scalatest.Assertions$class.intercept(Assertions.scala:822)
            at org.scalatest.FunSuite.intercept(FunSuite.scala:1560)
            at org.apache.spark.scheduler.BarrierTaskContextSuite$$anonfun$7.apply(BarrierTaskContextSuite.scala:94)
            at org.apache.spark.scheduler.BarrierTaskContextSuite$$anonfun$7.apply(BarrierTaskContextSuite.scala:76)
            at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
      

      The problem from the logs is that the first task to call barrier() took a while, and at that point the "slow" task was already running, so the sleep finishes before the 2s timeout runs out.

      Attachments

        Issue Links

          Activity

            People

              viirya L. C. Hsieh
              vanzin Marcelo Masiero Vanzin
              Votes:
              1 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: