reflect feedback

apache · Oct 12, 2024 · ebdb78d · ebdb78d
1 parent d731a1e
commit ebdb78d
Showing 1 changed file with 1 addition and 2 deletions.
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
@@ -234,8 +234,7 @@ abstract class StreamingJoinSuite
     // just make sure the query have no leftover data
     q.processAllAvailable()
 
-    // By default, it reads the state store from lastest committed batch.
-    // (Do we have a case where we have to look back on testing?)
+    // By default, it reads the state store from latest committed batch.
     val stateStoreDf = spark.read.format("statestore")
       .option(StateSourceOptions.JOIN_SIDE, joinSide)
       .option(StateSourceOptions.PATH, checkpointLoc)