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

Breaking changes for Flink 2.0

    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  
          2.
          		 Rename readFileStream from the StreamExecutionEnvironment Sub-task Open Unassigned  
          3.
          		 Remove deprecated configuration keys from ConfigConstants Sub-task Open Unassigned
          4.
          		 Remove Key interface Sub-task Open Unassigned  
          5.
          		 Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem Sub-task Open Unassigned  
          6.
          		 Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API Sub-task Open Unassigned  
          7.
          		 Offer separate API for watermark generation and timestamp extraction Sub-task Open Unassigned  
          8.
          		 Remove with method from CoGroupedStream and JoinedStream, and change apply method return type Sub-task Open Unassigned  
          9.
          		 Move RocksDB backend to proper package Sub-task Open Unassigned  
          10.
          		 Remove Parameter from WindowAssigner.getDefaultTrigger() Sub-task Open Unassigned  
          11.
          		 Unify "GlobalJobParameters" and "Configuration" Sub-task Open Unassigned  
          12.
          		 Remove IOReadableWritable from classes where not needed Sub-task Open Unassigned  
          13.
          		 Unify Stream Sinks and OutputFormats Sub-task Open Unassigned  
          14.
          		 Remove Checked Exceptions from State Interfaces Sub-task Open Unassigned  
          15.
          		 Remove Deprecated Methods from WindowedStream Sub-task Open Unassigned  
          16.
          		 Make Path immutable Sub-task Open Unassigned  
          17.
          		 Introduce backwards compatible state to task assignment Sub-task Open Unassigned  
          18.
          		 Remove all ad-hoc config loading via GlobalConfiguration Sub-task Open Unassigned  
          19.
          		 Use TypeComparator.hash() instead of Object.hashCode() for keying in DataStream API Sub-task Open Unassigned  
          20.
          		 Scala DataStream#addSink returns Java DataStreamSink Sub-task In Progress Unassigned  
          21.
          		 Consider changing the RichFunction#open method signature to take no arguments. Sub-task Reopened Unassigned  
          22.
          		 Remove ClassTag in Scala DataSet API Sub-task Open Unassigned  
          23.
          		 Fix LongValue hashCode Sub-task Open Unassigned  
          24.
          		 Do not expose keyed operations on ProcessFunction.Context Sub-task Open Unassigned  
          25.
          		 Drop canEqual() from TypeInformation, TypeSerializer, etc. Sub-task Open Unassigned  
          26.
          		 Use Java's Duration instead of Flink's Time Sub-task Open Unassigned  
          27.
          		 Drop ".returns()" for TypeInformation in the DataStream API Sub-task Open Unassigned  
          28.
          		 `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic Sub-task Open Unassigned

          Activity

            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