zifeif2 commented on code in PR #52773:
URL: https://github.com/apache/spark/pull/52773#discussion_r2491659344
##########
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/state/StateStoreCoordinatorSuite.scala:
##########
@@ -208,7 +208,7 @@ class StateStoreCoordinatorSuite extends SparkFunSuite with
SharedSparkContext {
if (badPartitions.contains(partitionId)) {
assert(latestSnapshotVersion.getOrElse(0) == 0)
} else {
- assert(latestSnapshotVersion.get >= 0)
+ assert(latestSnapshotVersion.get > 0)
Review Comment:
~~Actually, looks like HDFS snapshot version start from 0 so I should change
it back to >= 0 in case there is only one snapshot taken in HDFS state store~~
Actually looks like all success snapshot version should be larger than 0!
I'll make this change again in the next version.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
