Skip to content

Conversation

@xuyangzhong
Copy link
Contributor

What is the purpose of the change

Fix the NPE in DeltaJoinUtil#isFilterOnOneSetOfUpsertKeys when the upstream upsert key is null.

Brief change log

  • Fix the NPE in DeltaJoinUtil#isFilterOnOneSetOfUpsertKeys when the upstream upsert key is null.
  • Add tests

Verifying this change

Tests are added to verify this pr.

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

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

Documentation

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

@flinkbot
Copy link
Collaborator

flinkbot commented Nov 7, 2025

CI report:

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

@github-actions github-actions bot added the community-reviewed PR has been reviewed by the community. label Nov 7, 2025
@xuyangzhong xuyangzhong merged commit e9eafdf into apache:master Nov 10, 2025
xuyangzhong added a commit to xuyangzhong/flink that referenced this pull request Nov 10, 2025
xuyangzhong added a commit that referenced this pull request Nov 10, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

community-reviewed PR has been reviewed by the community.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants