Give CREDIT to Andrzej Zera for reproducers

HeartSaVioR · Oct 2, 2024 · 3d1dd36 · 3d1dd36
1 parent 17ac1af
commit 3d1dd36
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/MultiStatefulOperatorsSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/MultiStatefulOperatorsSuite.scala
@@ -878,7 +878,6 @@ class MultiStatefulOperatorsSuite
     testOutputWatermarkInJoin(join3, input1, -40L * 1000 - 1)
   }
 
-  // NOTE: This is the revise of the reproducer in SPARK-45637. CREDIT goes to @andrezjzera.
   test("SPARK-49829 time window agg per each source followed by stream-stream join") {
     val inputStream1 = MemoryStream[Long]
     val inputStream2 = MemoryStream[Long]

diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingJoinSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingJoinSuite.scala
@@ -2047,11 +2047,6 @@ class StreamingLeftSemiJoinSuite extends StreamingJoinSuite {
     )
   }
 
-  // scalastyle:off line.size.limit
-  // DISCLAIM: This is a revision of below test, which was a part of report in the dev mailing
-  // list. CREDIT goes to @andrezjzera.
-  // https://github.com/andrzejzera/spark-bugs/blob/abae7a3839326a8eafc7516a51aca5e0c79282a6/spark-3.5/src/test/scala/OuterJoinTest.scala#L86C3-L167C4
-  // scalastyle:on
   test("SPARK-49829 two chained stream-stream left outer joins among three input streams") {
     withSQLConf(SQLConf.STREAMING_NO_DATA_MICRO_BATCHES_ENABLED.key -> "false") {
       val memoryStream1 = MemoryStream[(Long, Int)]