[FLINK-19321] CollectSinkFunction does not define serialVersionUID

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.2, 1.12.0
• Fix Version/s: 1.11.3, 1.12.0
• Component/s: Table SQL / Runtime
• Labels: pull-request-available
• Assignee: zhuxiaoshang
• Reporter: Fabian Hueske
• Created: 21/Sep/20 09:28
• Updated: 19/Feb/21 07:22
• Resolved: 22/Sep/20 04:29

Description

The org.apache.flink.streaming.api.operators.collect.CollectSinkFunction function does not define a serialVersionUID.

Function objects are serialized using Java Serialization and should define a serialVersionUID.

If no o serialVersionUID is defined, Java automatically generates IDs to check compatibility of objects during deserialization. However, the generation depends on the environment (JVM, class version, etc.) and can hence lead to java.io.InvalidClassException even if the classes are compatible.

Issue Links

• links to: GitHub Pull Request #13442