Versions Compared

Old Version 17

changes.mady.by.user Weijie Guo

Saved on

compared with

New Version Current

changes.mady.by.user Zhanghao Chen

Saved on

Key

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

...

Discussion threadhttps://lists.apache.org/thread/m67s4qfrh660lktpq7yqf9docvvf5o9l
Vote threadhttps://lists.apache.org/thread/2xmcxs67xxzwool554fglrnklyvw348h
JIRA

Jira
serverASF JIRA
columnIdsissuekey,summary,issuetype,created,updated,duedate,assignee,reporter,priority,status,resolution
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-34037

Release<Flink Version>2.0

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

Method

Annotation

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

@PublicEvolving

(Postponed as some Flink built-in connectors still rely on Kryo for serialization)

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.

...