Hi beam community, So I had brought this issue in our slack channel but I guess this warrants a deeper discussion and if we do go about what is the POA for it.
So basically currently for Flink Runner we don’t support operator level parallelism which native Flink provides OOTB. So I was wondering what the community feels about having some way to pass parallelism for individual operators esp. for some of the existing IO’s Wanted to know what people think of this. Thanks Akshay I