This is an automated email from the ASF dual-hosted git repository.
kabhwan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from f86dc2b7e5c3 [SPARK-47848][SS] Fix thread safety issue around access
to loadedMaps in close function for hdfs store provider
add e6b7950f553c [SPARK-47788][SS] Ensure the same hash partitioning for
streaming stateful ops
No new revisions were added by this update.
Summary of changes:
.../partition-tests/randomSchemas | 1 +
.../partition-tests/rowsAndPartIds | Bin 0 -> 4862115 bytes
.../StreamingQueryHashPartitionVerifySuite.scala | 230 +++++++++++++++++++++
3 files changed, 231 insertions(+)
create mode 100644
sql/core/src/test/resources/structured-streaming/partition-tests/randomSchemas
create mode 100644
sql/core/src/test/resources/structured-streaming/partition-tests/rowsAndPartIds
create mode 100644
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQueryHashPartitionVerifySuite.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
