Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3957

Breaking changes for Flink 2.0

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    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.

      Attachments

        Issue Links

        relates to

        Improvement - An improvement or enhancement to an existing feature or task. FLINK-19558 Umbrella Ticket for upgrading the REST API

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

        Activity
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            rmetzger Robert Metzger
            Votes:
            0 Vote for this issue
            Watchers:
            29 Start watching this issue

            Dates

              Created:
              Updated:

              Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 40m
                40m

                Slack

                  Issue deployment