Hello! I attempted to set the parallelism for the watermarking operator to 4 using the

assignTimestampsAndWatermarks(watermarkStrategy).setParallelism(4)

method. However, I discovered that the parallelism of the

sourceFunction

and the timestamps/watermarks should match. Could you please clarify why this requirement exists? Thank you!

Are you getting an error? What is the error message?

I'm not getting an error, but when I look at the job graph I found that the parallelism is set to 1 (default) not 4.