From ebdb78d6c30497a46be0e031f4ab3755b12cf3a0 Mon Sep 17 00:00:00 2001 From: Jungtaek Lim Date: Sun, 13 Oct 2024 07:12:51 +0900 Subject: [PATCH] reflect feedback --- .../org/apache/spark/sql/streaming/StreamingJoinSuite.scala | 3 +-- 1 file changed, 1 insertion(+), 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 index 919e96d8dd3da..20b627fbb42ba 100644 --- 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)