大家好, 我使用 Flink 1.10.1 并尝试使用 Flink State Processor API 从Savepoint读取 flink state 状态。 当状态Type 是普通 Java type或 Java POJOs时, 运行良好。
当 Avro 生成的 Java class 用作状态类型 state type时,不工作。 在这种Avro class情况下是否需要额外的序列化 serializers? 谢谢 谭民
大家好, 我使用 Flink 1.10.1 并尝试使用 Flink State Processor API 从Savepoint读取 flink state 状态。 当状态Type 是普通 Java type或 Java POJOs时, 运行良好。
当 Avro 生成的 Java class 用作状态类型 state type时,不工作。 在这种Avro class情况下是否需要额外的序列化 serializers? 谢谢 谭民