Skip to content

Conversation

@Zakelly
Copy link
Contributor

@Zakelly Zakelly commented Feb 8, 2025

Backport to 2.0 for #26120

What is the purpose of the change

We have introduced the state v2 creating methods in StreamingRuntimeContext, but these methods have not exposed to RuntimeContext. Thus user may not be able to access the state via getRuntimeContext().getState.

Brief change log

  • Add Add constructors for state v2 descriptors that accept type class
  • Add state access interfaces in RuntimeContext

Verifying this change

This change is a trivial work without any test coverage.

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? no
  • If yes, how is the feature documented? not applicable

@flinkbot
Copy link
Collaborator

flinkbot commented Feb 8, 2025

CI report:

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

@Zakelly Zakelly changed the title [FLINK-37276] Add missing state v2 access interfaces in RuntimeContext [BP-2.0][FLINK-37276] Add missing state v2 access interfaces in RuntimeContext Feb 8, 2025
@Zakelly Zakelly merged commit bfdc6db into apache:release-2.0 Feb 10, 2025
@Zakelly Zakelly deleted the f37276-2.0 branch February 10, 2025 03:07
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