[ https://issues.apache.org/jira/browse/SPARK-23408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dongjoon Hyun updated SPARK-23408: ---------------------------------- Fix Version/s: 2.4.0 > Flaky test: StreamingOuterJoinSuite.left outer early state exclusion on right > ----------------------------------------------------------------------------- > > Key: SPARK-23408 > URL: https://issues.apache.org/jira/browse/SPARK-23408 > Project: Spark > Issue Type: Bug > Components: SQL, Tests > Affects Versions: 2.4.0 > Reporter: Marcelo Vanzin > Assignee: Tathagata Das > Priority: Minor > Fix For: 2.4.0, 3.0.0 > > > Seen on an unrelated PR. > https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/87386/testReport/org.apache.spark.sql.streaming/StreamingOuterJoinSuite/left_outer_early_state_exclusion_on_right/ > {noformat} > sbt.ForkMain$ForkError: org.scalatest.exceptions.TestFailedException: > Assert on query failed: Check total state rows = List(4), updated state rows > = List(4): Array(1) did not equal List(4) incorrect updates rows > org.scalatest.Assertions$class.newAssertionFailedException(Assertions.scala:528) > org.scalatest.FunSuite.newAssertionFailedException(FunSuite.scala:1560) > > org.scalatest.Assertions$AssertionsHelper.macroAssert(Assertions.scala:501) > > org.apache.spark.sql.streaming.StateStoreMetricsTest$$anonfun$assertNumStateRows$1.apply(StateStoreMetricsTest.scala:28) > > org.apache.spark.sql.streaming.StateStoreMetricsTest$$anonfun$assertNumStateRows$1.apply(StateStoreMetricsTest.scala:23) > > org.apache.spark.sql.streaming.StreamTest$$anonfun$liftedTree1$1$1$$anonfun$apply$14.apply$mcZ$sp(StreamTest.scala:568) > > org.apache.spark.sql.streaming.StreamTest$class.verify$1(StreamTest.scala:371) > > org.apache.spark.sql.streaming.StreamTest$$anonfun$liftedTree1$1$1.apply(StreamTest.scala:568) > > org.apache.spark.sql.streaming.StreamTest$$anonfun$liftedTree1$1$1.apply(StreamTest.scala:432) > > scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) > == Progress == > AddData to MemoryStream[value#19652]: 3,4,5 > AddData to MemoryStream[value#19662]: 1,2,3 > CheckLastBatch: [3,10,6,9] > => AssertOnQuery(<condition>, Check total state rows = List(4), updated state > rows = List(4)) > AddData to MemoryStream[value#19652]: 20 > AddData to MemoryStream[value#19662]: 21 > CheckLastBatch: > AddData to MemoryStream[value#19662]: 20 > CheckLastBatch: [20,30,40,60],[4,10,8,null],[5,10,10,null] > == Stream == > Output Mode: Append > Stream state: {MemoryStream[value#19652]: 0,MemoryStream[value#19662]: 0} > Thread state: alive > Thread stack trace: java.lang.Thread.sleep(Native Method) > org.apache.spark.sql.execution.streaming.MicroBatchExecution$$anonfun$runActivatedStream$1.apply$mcZ$sp(MicroBatchExecution.scala:152) > org.apache.spark.sql.execution.streaming.ProcessingTimeExecutor.execute(TriggerExecutor.scala:56) > org.apache.spark.sql.execution.streaming.MicroBatchExecution.runActivatedStream(MicroBatchExecution.scala:120) > org.apache.spark.sql.execution.streaming.StreamExecution.org$apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.scala:279) > org.apache.spark.sql.execution.streaming.StreamExecution$$anon$1.run(StreamExecution.scala:189) > {noformat} > No other failures in the history, though. -- This message was sent by Atlassian JIRA (v7.6.3#76005) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org