[FLINK-40597][core] Fix input type validation for Types.UUID - #29133
Open
dylanhz wants to merge 1 commit into
Open
[FLINK-40597][core] Fix input type validation for Types.UUID#29133dylanhz wants to merge 1 commit into
dylanhz wants to merge 1 commit into
Conversation
dylanhz
marked this pull request as ready for review
September 8, 2026 16:05
Collaborator
dylanhz
force-pushed
the
codex/fix-uuid-type-validation
branch
2 times, most recently
from
September 9, 2026 09:03
3936022 to
e0c0526
Compare
Generated-by: Codex 0.147.0 (model: gpt-6)
dylanhz
force-pushed
the
codex/fix-uuid-type-validation
branch
from
September 9, 2026 11:38
e0c0526 to
ccfe431
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
What is the purpose of the change
Fix FLINK-40597: a DataStream created with explicit
Types.UUIDcan fail input type validation for a non-lambdaMapFunction<UUID, String>withInput mismatch: Basic type expected.Brief change log
java.util.UUIDwhen validating explicitly specified basic type information.GenericTypeInfo<UUID>with Kryo by default). Automatic extraction asTypes.UUIDis tracked separately in FLINK-40546.Verifying this change
fromData(Types.UUID, ...).map(...)regression test and a check thatfromData(...)still infersGenericTypeInfo<UUID>.DataStreamTestandTypeExtractorTest: 102 tests passed after rebasing onto master../mvnw clean verifywas attempted. After resolving a local Python executable issue and resuming, verification stopped atflink-s3-fs-base:SeaweedFsTestContainerTestrequires Docker, which is not installed locally. Subsequent modules have not been verified.Does this pull request potentially affect one of the following parts:
@PublicTypeExtractor; no API signatures changeDocumentation
Was generative AI tooling used to co-author this PR?
Generated-by: Codex 0.147.0 (model: gpt-6)