[FLINK-31873] Add setMaxParallelism to the DataStreamSink Class

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.18.0
• Fix Version/s: 1.18.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Eric Xiao
• Reporter: Eric Xiao
• Created: 20/Apr/23 20:24
• Updated: 28/Apr/23 14:35
• Resolved: 28/Apr/23 14:35

Description

When turning on Flink reactive mode, it is suggested to convert all setParallelism calls to setMaxParallelism from elastic scaling docs.

With the current implementation of the DataStreamSink class, only the setParallelism function of the Transformation class is exposed - Transformation also has the setMaxParallelism function which is not exposed.

 

This means for any sink in the Flink pipeline, we cannot set a max parallelism.

Issue Links

• duplicates: FLINK-21711 DataStreamSink doesn't allow setting maxParallelism
• links to: GitHub Pull Request #22438