Hi, Currently we use sbt-avrohugger [0] to generate key class for keyed state. The key class generated by sbt-avrohugger is both case class, and AVRO specific record. However, in the following scenarons, Flink uses different serializers:
* In streaming application, Flink uses CaseClassSerializer for key class. * In state processor API application, Flink uses AvroSerializer for key class. Since they use different serializers for key, they are not compatible. Is there any way to specific key serializer so that both applications use the same serializer? [0] https://github.com/julianpeeters/sbt-avrohugger -- ChangZhuo Chen (陳昌倬) czchen@{czchen,debian}.org http://czchen.info/ Key fingerprint = BA04 346D C2E1 FE63 C790 8793 CC65 B0CD EC27 5D5B
signature.asc
Description: PGP signature
