Closed shmilygkd closed 1 year ago
In other words, if we got HTTP error code or HTTP connection was disconnected (network issues etc) or the endpoint is unavailable - in that case flink job is not restarted right?
And you are asking whether this is a feature or a bug correct? :)
Yes, the flink task does not seem to have any perception on the surface, but the downstream http can no longer receive data, i'm not sure if this is a bug.
If I remember correctly this is by design (so not a bug :) )
The reasons for this were:
The second point is missing two things to be perfect:
What you have however is a metric of failed requestest. So you can monitor this and react up on its value. There is a test that covers "FailledConenction" HttpSinkConnectionTest:testFailedConnection
Thank you for your patient reply. Let me think about it again~
As the title suggests, when the http service configured in the http sink is launched after starting the flink app, the flink application will not try to restart or fail because the connection is rejected or the connection is unavailable. Can I get a reasonable explanation? thanks.