Hi Ashwin, Do you have any filtering or aggregation (or any operation that emits less data than it receives) in your logic? If yes, you could for example put if before the reschaling operation so that it gets chained to your source and you reduce the amount of data you ship through the network. After that, then it boils down to optimizing your code I guess, as Till said. Also you can check if the rescaling has any effect, because if not, then you could also remove it.
Kostas On Mon, Nov 9, 2020 at 10:12 AM ashwinkonale <ashwin.kon...@gmail.com> wrote: > > Hi Till, > Thanks a lot for the reply. The problem I am facing is as soon as I add > network(remove chaining) to discarding sink, I have huge problem with > throughput. Do you have any pointers on how can I go about debugging this ? > > - Ashwin > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
