GitHub user duguyue8 created a discussion: Flink 1.18 FlinkSQL jobs
consistently report `java.net.ConnectException: yarnUtils restRequest error,
url: xxx` when reading from or writing to Kafka.
2025-09-06 01:00:34 | INFO | streampark-flink-app-watching-5 |
org.apache.http.impl.execchain.RetryExec:97] I/O exception
(org.apache.http.NoHttpResponseException) caught when processing request to
{}->http://linux101:39468: The target server failed to respond
2025-09-06 01:00:34 | INFO | streampark-flink-app-watching-5 |
org.apache.http.impl.execchain.RetryExec:113] Retrying request to
{}->http://linux101:39468
2025-09-06 01:00:34 | WARN | streampark-flink-app-watching-5 |
org.apache.streampark.console.core.task.FlinkAppHttpWatcher:223] [StreamPark]
get state from flink failed
java.net.ConnectException: yarnUtils restRequest error, url:
http://linux101:39468/jobs/overview, detail:
org.apache.http.conn.HttpHostConnectException: Connect to linux101:39468
[linux101/192.168.99.66] failed: Connection refused (Connection refused)
at
org.apache.streampark.common.util.YarnUtils$.restRequest(YarnUtils.scala:236)
at
org.apache.streampark.common.util.YarnUtils.restRequest(YarnUtils.scala)
at
org.apache.streampark.console.core.task.FlinkAppHttpWatcher.yarnRestRequest(FlinkAppHttpWatcher.java:801)
at
org.apache.streampark.console.core.task.FlinkAppHttpWatcher.httpJobsOverview(FlinkAppHttpWatcher.java:751)
at
org.apache.streampark.console.core.task.FlinkAppHttpWatcher.getFromFlinkRestApi(FlinkAppHttpWatcher.java:297)
at
org.apache.streampark.console.core.task.FlinkAppHttpWatcher.lambda$watch$2(FlinkAppHttpWatcher.java:220)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
GitHub link: https://github.com/apache/streampark/discussions/4283
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
