Hello guys

One question, I have a side input which fetches an endpoint each 30
min, I pretty much copied the example here:
https://beam.apache.org/documentation/patterns/side-inputs/ but added
some logic to fetch the endpoint and parse the payload.

My question is: it is possible to control the parallelism of this
single ParDo that does the fetch/transform? I don't think I need a lot
of parallelism for that one. I'm currently using flink runner and I
see the parallelism is 8 (which is the general parallelism for my
flink cluster).

Is it possible to set it to 1 for example?


Regards.

Reply via email to