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

DataStreamSink doesn't allow setting maxParallelism

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.11.3, 1.12.2, 1.13.0
    • Fix Version/s: 1.11.4, 1.14.0, 1.12.4
    • Component/s: API / DataStream
    • Labels:
      None

      Description

      It seems that we can only set the max parallelism of the sink only via this internal API:

              input.addSink(new ParallelismTrackingSink<>()).getTransformation().setMaxParallelism(1);
      
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              rmetzger Robert Metzger
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated: