Skip to content

[FLINK-39379][table] Add state management to PTF test harness#28212

Open
autophagy wants to merge 1 commit into
apache:masterfrom
autophagy:flink-39379-state
Open

[FLINK-39379][table] Add state management to PTF test harness#28212
autophagy wants to merge 1 commit into
apache:masterfrom
autophagy:flink-39379-state

Conversation

@autophagy
Copy link
Copy Markdown
Contributor

What is the purpose of the change

The PTF Test Harness currently does not support any use of state. This PR adds support for PTFs with state (map, list and pojo) and injects the state into the eval of the PTF being tested (based on the partition key/s). When eval completes, the state is then converted into an internal format (Map/List/RowData) to also provide testing of state serialization.

It currently doesn't support state TTL.

Brief change log

  • Added state support for ProcessTableFunctionTestHarness.
  • Refactored some minor things (argument info, how scalar argument values are stored/handled)

Verifying this change

This change added tests and can be verified by the state tests in ProcessTableFunctionTestHarnessTest.

Does this pull request potentially affect one of the following parts:

  • Dependencies (does it add or upgrade a dependency): (no)
  • The public API, i.e., is any changed class annotated with @Public(Evolving): (no)
  • The serializers: (no)
  • The runtime per-record code paths (performance sensitive): (no)
  • Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (no)
  • The S3 file system connector: (no)

Documentation

  • Does this pull request introduce a new feature? (yes)
  • If yes, how is the feature documented? (docs)

Was generative AI tooling used to co-author this PR?
  • Yes (please specify the tool below)

Generated-by: 2.1.145 (Claude Code)

@flinkbot
Copy link
Copy Markdown
Collaborator

flinkbot commented May 20, 2026

CI report:

Bot commands The @flinkbot bot supports the following commands:
  • @flinkbot run azure re-run the last Azure build

@autophagy autophagy force-pushed the flink-39379-state branch 7 times, most recently from 3d0e53c to 9e7a752 Compare May 20, 2026 10:15
Does not currentlty include handling State TTL.
@autophagy autophagy changed the title [FLINK-39379] Add state management to PTF test harness [FLINK-39379][table] Add state management to PTF test harness May 20, 2026
@autophagy autophagy force-pushed the flink-39379-state branch from 9e7a752 to 2a07d3e Compare May 20, 2026 13:55
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants