Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-3957 Breaking changes for Flink 2.0
  3. FLINK-4503

Remove with method from CoGroupedStream and JoinedStream, and change apply method return type

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 2.0-preview
    • API / DataStream
    • None

    Description

      We introduced (and immediately deprecated) the with(...) method in FLINK-4271. It is a temporary workaround for setting parallelism after co-group and join operator and not breaking binary compatibility. The with(...) method only differs in the return type and calls apply(...), casting the returned value.

      So we need to remove the with(...) method in Flink 2.0. And change the apply method return type.

      Attachments

        Activity

          People

            yyhx xuhuang
            jark Jark Wu
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: