Re: Specifying parallelism on join operation

You can use with(JoinFunction) to workaround it. See JavaDoc for Flink 1.8: @PublicEvolving

Specifying parallelism on join operation

I cant find any place to specify the parallelism for the join here.  stream1.join( stream2 )                      .where( .. )                     .equalTo( .. )                     .window( .. )                     .apply( .. ); How can we specify that ?  -roshan