Is there a method for a running Flink app get back pressure status?
In the Java code for a Flink app, is there a way to tell if the app is currently experiencing back pressure? Flink produces back pressure metrics that we can monitor from outside the app, but I’m not currently finding anything in the Java API that would allow the application itself to know if it were experiencing back pressure.
Is there a method for a running Flink app get back pressure status?
In the Java code for a Flink app, is there a way to tell if the app is currently experiencing back pressure? Flink produces back pressure metrics that we can monitor from outside the app, but I’m not currently finding anything in the Java API that would allow the application itself to know if it were experiencing back pressure.
Is there a method for a running Flink app get back pressure status?
In the Java code for a Flink app, is there a way to tell if the app is currently experiencing back pressure? Flink produces back pressure metrics that we can monitor from outside the app, but I’m not currently finding anything in the Java API that would allow the application itself to know if it were experiencing back pressure.