Flink-CEP-PojoSerializer多态性解析错误

Question

目前，当我打印CEP模式的结果时，我有一个非常奇怪的行为。

数据模型如下：

< li >事件:(类型:字符串，时间戳:长整型) < li >车辆相关扩展事件:(vehicleId:Integer) < li >位置延伸车辆相关:(位置:整数，方向:整数) < li >识别扩展车辆相关:(位置:整数，id:整数，方向:整数)

CEP部分如下所示：

val pattern = Pattern
  .begin[VehicleRelated]("before")
  .subtype(classOf[Position])
  .next("recognize")
  .subtype(classOf[Recognize])
  .next("after")
  .subtype(classOf[Position])
  .within(Time.seconds(5))

val patternStream = CEP.pattern(actionEvents, pattern)
val recognitions = patternStream
  .select(pattern => {
    val s = pattern("recognize").head.asInstanceOf[Recognize]
    LOG.debug(s.toString)
    s
  })

recognitions.print("RECO")

日志的输出如下：

14:45:27,286 DEBUG stoff.schnaps.RecognizingJob$ - Recognize(VehicleId: 2, Id: 601, Pos: 1601, Direction: 35, Add: Map())
RECO:8> Recognize(VehicleId: null, Id: 601, Pos: 1601, Direction: 35, Add: Map())

现在最大的问题是，为什么在我返回强制转换的对象后，vehicleId 属性为 null？有什么建议吗？

更新：我做了一些调查，发现PojoSerializer是问题所在。将调用复制函数，并在第151行中执行此操作。numFields错误..计数仅包括识别类本身的属性计数，但不包括继承类，在本例中为事件和车辆相关..属性类型和时间戳也为空。。

Answer 1

问题是flink内部POJO序列化器无法正确解析多态性。

因此，我将Kyro序列化器设置为默认值：

val config = env.getConfig
config.enableForceKryo()