Hi Puneet,
can you share a little code example with us? I could not reproduce your
problem.
You have to keep in mind that a setParallelism() only affects the last
operation. If you want to change the default parallelism of the entire
pipeline, you have to change it in StreamExecutionEnvironment. Otherwise
every following operator will again have the full parallelism which
leads to a shuffle operation after your source.
I hope this helps.
Regards,
Timo
Am 22.03.18 um 09:17 schrieb Puneet Kinra:
if i set parallelsim equals to 1 still it create multiple splits while
processing.
--
*Cheers *
*
*
*Puneet Kinra*
*
*
*Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
*e-mail :puneet.ki...@customercentria.com
<mailto:puneet.ki...@customercentria.com>*
