Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19435#discussion_r142836474
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala
---
@@ -291,7 +291,7 @@ class SymmetricHashJoinStateManager(
}
/** A wrapper around a [[StateStore]] that stores [(key, index) ->
value]. */
- private class KeyWithIndexToValueStore extends
StateStoreHandler(KeyWithIndexToValuesType) {
+ private class KeyWithIndexToValueStore extends
StateStoreHandler(KeyWithIndexToValueType) {
--- End diff --
dropped the 's' from '...Values...'
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
