Hi Team, We are migrating our codebase of flink to V2.1 version. Here were using dataset jobs which we need to migrate to data stream now and while doing this we faced an error of parallelism of keyby and window function in our full outerjoin function which is creating bottleneck for us in case of disk storage and compute
The code structure We have 2 inputs db2stream and kafka input on which we perform outerjoin function Db2Stream.keyby(key selector) .cogroup(kafka input) .where(key) .equalto(key) .window(endOfStreamWindow.get) .apply(<join function>) Can you please help me with increasing Parallelism of this function in anyway so that we can remove our bottleneck while migrating it from dataset to datastream Thanks, Sambhav Gupta
