[FLINK-3957] Breaking changes for Flink 2.0

• Type: New Feature
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.0.0
• Fix Version/s: 2.0.0
• Component/s: API / DataSet, API / DataStream, Build System
• Labels: 2.0-related auto-deprioritized-major
• Assignee: Unassigned
• Reporter: Robert Metzger
• Created: 23/May/16 14:06
• Updated: 03/Aug/23 09:57

Description

From time to time, we find APIs in Flink (1.x.y) marked as stable, even though we would like to change them at some point.

This JIRA is to track all planned breaking API changes.

I would suggest to add subtasks to this one.

Issue Links

• relates to: FLINK-19558 Umbrella Ticket for upgrading the REST API

Sub-Tasks

• Remove implicit sinks: Open
• Rename readFileStream from the StreamExecutionEnvironment: Open
• Remove deprecated configuration keys from ConfigConstants: Open
• Remove Key interface: Open
• Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem: Open
• Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time: Resolved
• Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API: Open
• Offer separate API for watermark generation and timestamp extraction: Open
• Remove with method from CoGroupedStream and JoinedStream, and change apply method return type: Open
• Move RocksDB backend to proper package: Open
• Remove Parameter from WindowAssigner.getDefaultTrigger(): Open
• Unify "GlobalJobParameters" and "Configuration": Open
• Remove IOReadableWritable from classes where not needed: Open
• Unify Stream Sinks and OutputFormats: Open
• Remove Checked Exceptions from State Interfaces: Open
• Remove Deprecated Methods from WindowedStream: Open
• StreamExecutionEnvironment's set function return `this` instead of void: Closed
• Make Path immutable: Open
• Introduce backwards compatible state to task assignment: Open
• Make printing sinks non-parallel: Closed
• Remove all ad-hoc config loading via GlobalConfiguration: Open
• Use TypeComparator.hash() instead of Object.hashCode() for keying in DataStream API: Open
• Make flink-core independent of Avro: Closed
• Scala DataStream#addSink returns Java DataStreamSink: In Progress
• Consider changing the RichFunction#open method signature to take no arguments.: Reopened
• Remove ClassTag in Scala DataSet API: Open
• Fix LongValue hashCode: Open
• Do not expose keyed operations on ProcessFunction.Context: Open
• Drop canEqual() from TypeInformation, TypeSerializer, etc.: Open
• Use Java's Duration instead of Flink's Time: Open
• Drop ".returns()" for TypeInformation in the DataStream API: Open
• `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic: Open
• Deprecate API that uses Flink's Time implementation (related to FLINK-14638): Closed