raminqaf commented on code in PR #29087:
URL: https://github.com/apache/flink/pull/29087#discussion_r3925960240
##########
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicTypeInfo.java:
##########
@@ -338,5 +344,9 @@ private static <X> TypeComparator<X> instantiateComparator(
TYPES.put(BigInteger.class, BIG_INT_TYPE_INFO);
TYPES.put(BigDecimal.class, BIG_DEC_TYPE_INFO);
TYPES.put(Instant.class, INSTANT_TYPE_INFO);
+ // UUID is intentionally not registered here. Automatic reflective
extraction of
+ // java.util.UUID to UUID_TYPE_INFO in the DataStream API stays opt-in
via Types.UUID to
+ // avoid silently changing the serializer of existing java.util.UUID
fields (currently
+ // handled by Kryo). This is planned to change in the next major Flink
version.
Review Comment:
Created: https://issues.apache.org/jira/projects/FLINK/issues/FLINK-40546
##########
flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java:
##########
@@ -158,6 +159,9 @@ public class Types {
/** Returns type information for {@link java.time.Instant}. Supports a
null value. */
public static final TypeInformation<Instant> INSTANT =
BasicTypeInfo.INSTANT_TYPE_INFO;
+ /** Returns type information for {@link java.util.UUID}. Supports a null
value. */
Review Comment:
Removed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
