Skip to content

[SPARK-55106][SS] Add Repartition Integration test for TransformWithState Operators#53899

Closed
zifeif2 wants to merge 12 commits intoapache:masterfrom
zifeif2:test-tws
Closed

[SPARK-55106][SS] Add Repartition Integration test for TransformWithState Operators#53899
zifeif2 wants to merge 12 commits intoapache:masterfrom
zifeif2:test-tws

Conversation

@zifeif2
Copy link
Copy Markdown
Contributor

@zifeif2 zifeif2 commented Jan 21, 2026

What changes were proposed in this pull request?

Adding offline repartitions integration test for transformWithState operators
Tested operators include

  • TWS with multiple column families
  • event time timers
  • processing time timers
  • TTL
  • state with List Type and Map Type

Main changes in util functions:

  • testRepartitionWorkflow supports selectExprs
  • Verify before-vs-after-repartition data by serializing the entire row to string instead of just extracting key and value

Why are the changes needed?

Ensure that OfflineRepartitionRunner is running as expected

Does this PR introduce any user-facing change?

No

How was this patch tested?

See added unit tests

Was this patch authored or co-authored using generative AI tooling?

Yes, Sonnet 4.5

@github-actions
Copy link
Copy Markdown

JIRA Issue Information

=== New Feature SPARK-55106 ===
Summary: Test repartition for TransformWithState
Assignee: None
Status: Open
Affected: ["4.1.1"]


This comment was automatically generated by GitHub Actions

@zifeif2 zifeif2 force-pushed the test-tws branch 4 times, most recently from 4a875f8 to 7323dd4 Compare January 24, 2026 02:04
@zifeif2 zifeif2 marked this pull request as ready for review January 24, 2026 02:07
@zifeif2 zifeif2 force-pushed the test-tws branch 2 times, most recently from de0344a to c198299 Compare January 26, 2026 18:23
@zifeif2 zifeif2 force-pushed the test-tws branch 2 times, most recently from 56e3de2 to 0c7da7a Compare January 28, 2026 22:01
@zifeif2 zifeif2 force-pushed the test-tws branch 3 times, most recently from 538dc62 to e55c3be Compare February 2, 2026 17:56
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants