Versions Compared

Old Version 9

changes.mady.by.user Zhanghao Chen

Saved on

compared with

New Version 10

changes.mady.by.user Zhanghao Chen

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Method

Annotation

org.apache.flink.api.common.typeinfo#createSerializer(SerializerConfig config)

@PublicEvolving

Also, the following nested class in ExecutionConfig will be explicitly marked @Public, as required by the ArchTest rule "Return and argument types of methods annotated with @PublicEvolving must be annotated with @Public(Evolving)":

...

Class

...

Annotation

...

org.apache.flink.api.common.ExecutionConfig.SerializableSerializer

...

@Public






Currently, option pipeline.generic-types in Flink is used to enable/disable Kryo serialzier, its default value is true which means Flink will use Kryo as fallback serializer. This causes Kryo to be used by default to serialize some user-defined data without the user being aware of it, which can lead to incompatibility between the new and old versions of the job state during version upgrades. To avoid this issue, in Flink-2.0 , the default value of pipeline.generic-types can be changed to false to prevent the usage of the Kryo serializer without the user's knowledge.

...