[jira] [Created] (FLINK-36404) PrometheusSinkWriteException thrown by the response callback may not cause job to fail

["Lorenzo Nicora (Jira)" <ji...@apache.org>]

Lorenzo Nicora created FLINK-36404:
--------------------------------------

             Summary: PrometheusSinkWriteException thrown by the response callback may not cause job to fail
                 Key: FLINK-36404
                 URL: https://issues.apache.org/jira/browse/FLINK-36404
             Project: Flink
          Issue Type: Sub-task
          Components: Connectors / Prometheus
            Reporter: Lorenzo Nicora


*Issue*
{{PrometheusSinkWriteException}} thrown by {{HttpResponseCallback}} do not cause the httpclient IOReactor to fail, being actually swallowed, and preventing the job from failing.

*Solution*
Intercept {{PrometheusSinkWriteException}} up the httpclient stack, adding to the client a {{IOSessionListener}} to that can rethow those exceptions, causing the reactor to actually fail, and consequently also the operator to fail.

Note: the httpclient IOReactor failing causes a number of exceptions. To keep the actual root cause evident, the response callback should log to ERROR when the exception happens



--
This message was sent by Atlassian Jira
(v8.20.10#820010)