tdas commented on a change in pull request #26162: [SPARK-29438][SS] Use
partition ID of StateStoreAwareZipPartitionsRDD for determining partition ID of
state store in stream-stream join
URL: https://github.com/apache/spark/pull/26162#discussion_r368338229
##########
File path:
sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManagerSuite.scala
##########
@@ -170,7 +170,7 @@ class SymmetricHashJoinStateManagerSuite extends
StreamTest with BeforeAndAfter
val stateInfo = StatefulOperatorStateInfo(file.getAbsolutePath,
UUID.randomUUID, 0, 0, 5)
val manager = new SymmetricHashJoinStateManager(
LeftSide, inputValueAttribs, joinKeyExprs, Some(stateInfo), storeConf,
new Configuration,
- stateFormatVersion)
+ 0, stateFormatVersion)
Review comment:
super nit: for such constant values, its more readable to write it as
"paramName = value"
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
