You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@streampark.apache.org by "duguyue8 (via GitHub)" <gi...@apache.org> on 2025/09/06 02:19:32 UTC

Re: [D] 跑flinksql的demo时正常，换成kafka source时总是报错 [streampark]

GitHub user duguyue8 edited a discussion: 跑flinksql的demo时正常，换成kafka source时总是报错

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 dev@streampark.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@streampark.apache.org