Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/spark/pull/21700#discussion_r202932784 --- Diff: sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/state/StateStoreSuite.scala --- @@ -64,21 +64,122 @@ class StateStoreSuite extends StateStoreSuiteBase[HDFSBackedStateStoreProvider] require(!StateStore.isMaintenanceRunning) } + def updateVersionTo(provider: StateStoreProvider, currentVersion: => Int, + targetVersion: Int): Int = { --- End diff -- Thanks for correcting style guide. Will fix. Regarding `currentVersion: => Int` is somehow I was trying to reuse currentVersion and didn't roll back. Will fix. And I agree it would be better to have `incrementVersion` to shorter the code. Will address.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org