Eric Xiao
04/19/2023, 9:05 PMsetParallelism calls to setMaxParallelism , I noticed for sinks (DataStreamSink), there is no setMaxParallelism function. We do not want to use a global parallelism setting to control the sink's parallelism as other operators will have a higher parallelism count.
Is there another way we can set a max parallelism on a sink in our pipeline?Eric Xiao
04/20/2023, 8:36 PMsetMaxParallelism is not a function for the DataStreamSink class. I opened a JIRA ticket and https://issues.apache.org/jira/browse/FLINK-31873
and opened a PR to add the function: https://github.com/apache/flink/pull/22438