Hi, we are using Flink reactive mode and we're swi...
# troubleshooting
e
Hi, we are using Flink reactive mode and we're switching all
setParallelism
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?
I noticed that
setMaxParallelism
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