我们的一些POJO包含来自java.time接口(LocalDate,LocalDateTime)的字段。当我们的管道处理它们时,我们可以在日志中看到以下信息:
org.apache.flink.api.java.typeutils.TypeExtractor - Class class java.time.LocalDate据我所知,LocalDate不能归类为POJO,所以flink不使用POJO序列化<
我有一个关于在Flink中使用MapValue的问题,因为我需要将映射保存为状态的一部分,因为您知道状态需要是反序列化/可序列化的,所以我从MapValue扩展了类,因为MapValue是一个抽象类。(ReflectionUtil.java:98)
at org.apache.flink.util.ReflectionUtil.getTemplateType(ReflectionUtil.j