Hi, I am running one of the apex application which contains multiple operators. For some operators I assigned >1 partitions as it has to do some heavy lifting compared to other operators. Like kafka operator I have given 2 partitions.
Now thing is I restarted the running application which got killed after 2-3 days and after that I see there is huge latency in some of the operators.Even after 2-3 days latency no is huge and application is not able to process today's record. So please suggest me how to handle this kind of scenario. when we restart application and if we see huge latency no. Thanks Rishi -- View this message in context: http://apache-apex-users-list.78494.x6.nabble.com/how-to-decide-no-of-operator-partitions-tp1580.html Sent from the Apache Apex Users list mailing list archive at Nabble.com.
