Hi all!

The ExecutionConfig has some very old settings: forceAvro() and
forceKryo(), which are actually misleadingly named. They cause POJOs to use
Avro or Kryo rather than the POJO serializer.

I think we do not have a good case any more to use Avro for POJOs. POJOs
that are also Avro types go through the Avro serializer anyways.

There may be a case to use Kryo for POJOs if you don't like the Flink POJO
serializer.

I would suggest to remove the "forceAvro()" option completely.
For "forceKryo()", I am torn between removing it completely or renaming it
to "setUseKryoForPOJOs()".

What are the opinion on that out there?

Best,
Stephan

Reply via email to