Skip to content

Commit 69c3eb9

Browse files
WweiLLuciferYang
authored andcommitted
[SPARK-52188][FOLLOWUP] Update comment in getRunId
### What changes were proposed in this pull request? #50924 removed the logic of generating a random id in `StateStoreProvider.getRunId` didn't update the comment. Following discussion here, update the comment #51304 (comment) ### Why are the changes needed? Code readability ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? No need ### Was this patch authored or co-authored using generative AI tooling? No Closes #51307 from WweiL/SPARK-52188-followup. Authored-by: Wei Liu <[email protected]> Signed-off-by: yangjie01 <[email protected]>
1 parent 99acf64 commit 69c3eb9

File tree

1 file changed

+1
-1
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -664,7 +664,7 @@ object StateStoreProvider extends Logging {
664664
}
665665

666666
/**
667-
* Get the runId from the provided hadoopConf. If it is not found, generate a random UUID.
667+
* Get the runId from the provided hadoopConf. If it is not found, an error will be thrown.
668668
*
669669
* @param hadoopConf Hadoop configuration used by the StateStore to save state data
670670
*/

0 commit comments

Comments
 (0)