Wei Liu

Why setting cv->head to next of new node

2

https://github.com/illinois-cs241/coursebook/blob/1b53e6d38f4fff1f45fc25efd3a24111de35383e/appendix/appendix.tex#L846 I was wondering the purpose of this line here. It seems that it is setting the head again to itself so essentially this line doesn't do anything. Should it...

[SPARK-40495] [SQL] [TESTS] Add additional tests to StreamingSessionWindowSuite

3

## What changes were proposed in this pull request? Add complex tests to `StreamingSessionWindowSuite`. Concretely, I created two helper functions, - one is called `sessionWindowQueryNestedKey`, which would convert `sessionId` from...

[SPARK-47035][SS][CONNECT] Protocol for Client-Side Listener

1

### What changes were proposed in this pull request? Currently, the StreamingQueryListener for Connect runs on the server side. From the user point of view, the purpose of a listener...

Make the error looks better. Some inconsistency here and [here](https://github.com/WweiL/rocksdb/blob/e46ab9d4f0a0e63bfc668421e2994efa918d6570/db/db_impl/db_impl_compaction_flush.cc#L2701-L2702)

[SPARK-48743][SS]MergingSessionIterator should better handle when getStruct returns null

1

### What changes were proposed in this pull request? The getStruct() method used in `MergingSessionIterator.initialize` could return a null value. When that happens, the copy() called upon it throws a...

### What changes were proposed in this pull request? ### Why are the changes needed? ### Does this PR introduce _any_ user-facing change? ### How was this patch tested? ###...

[SPARK-48482][PYTHON][FOLLOWUP] dropDuplicates and dropDuplicatesWIthinWatermark should accept named parameter

2

### What changes were proposed in this pull request? https://github.com/apache/spark/commit/560c08332b35941260169124b4f522bdc82b84d8 unintentionally made `dropDuplicates(subset=["col"])` doesn't work, this patches this scenario. ### Why are the changes needed? Bug fix ### Does this...

[SPARK-49461][SS] Persistent Checkpoint ID to commit logs and read it back

1

### What changes were proposed in this pull request? In this change, we propose to add a new field to the commit log if `STREAMING_STATE_STORE_COMMIT_LOG_VERSION` is 2. The new field...

[DO-NOT-REVIEW] [SPARK-49883][SS] State Store Checkpoint Structure V2 Integration with RocksDB and RocksDBFileManager

1

### What changes were proposed in this pull request? This PR enables RocksDB to read file watermarked with unique ids (e.g. `version_uniqueId.zip`, `version_uniqueId.changelog`). Below is a explanation on the changes...

### What changes were proposed in this pull request? ### Why are the changes needed? ### Does this PR introduce _any_ user-facing change? ### How was this patch tested? ###...