Robert Metzger created FLINK-21711: -------------------------------------- Summary: DataStreamSink doesn't allow setting maxParallelism Key: FLINK-21711 URL: https://issues.apache.org/jira/browse/FLINK-21711 Project: Flink Issue Type: Improvement Components: API / DataStream Affects Versions: 1.13.0 Reporter: Robert Metzger
It seems that we can only set the max parallelism of the sink only via this internal API: {code} input.addSink(new ParallelismTrackingSink<>()).getTransformation().setMaxParallelism(1); {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)