minor

eason-yuchen-liu · Jun 11, 2024 · 61dea35 · 61dea35
1 parent 1656580
commit 61dea35
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala
@@ -379,8 +379,8 @@ trait StateStoreProvider {
     new WrappedReadStateStore(getStore(version))
 
   /**
-   * This is an optional method, used by snapshotBatchId option when reading state as data source.
-   *
+   * This is an optional method, used by snapshotStartBatchId option when reading state as data
+   * source.
    * Return an instance of [[ReadStateStore]] representing state data of the given version.
    * The State Store will be constructed from the batch at startVersion, and applying delta files
    * up to the endVersion. If there is no snapshot file of batch startVersion, an exception will