跑flinksql的demo时正常，换成kafka source时总是报错

[duguyue8]

streampark2.1.6版本
2025-09-06 10:11:16 | WARN | streampark-flink-app-watching-6 | org.apache.streampark.console.core.task.FlinkAppHttpWatcher:223] [StreamPark] get state from flink failed
java.net.ConnectException: yarnUtils restRequest error, url: http://linux101:35792/jobs/overview, detail: org.apache.http.conn.HttpHostConnectException: Connect to linux101:35792 [linux101/192.168.77.88] 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)
2025-09-06 10:11:17 | WARN | streampark-flink-app-watching-4 | org.apache.streampark.console.core.task.FlinkAppHttpWatcher:223] [StreamPark] get state from flink failed
com.fasterxml.jackson.core.JsonParseException: Unexpected character ('<' (code 60)): expected a valid value (JSON String, Number, Array, Object or token 'null', 'true' or 'false')
at [Source: (String)"

<style type="text/css"> #attempts_paginate span {font-weight:normal} #attempts .progress {width:8em} #attempts_processing {top:-1.5em; font-size:1em; color:#000; background:#fefefe} #attempts .queue {width:6em} #attempts .ui {width:8em} </style> <"[truncated 14319 chars]; line: 1, column: 2] at com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:2391) at com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:735) at com.fasterxml.jackson.core.base.ParserMinimalBase._reportUnexpectedChar(ParserMinimalBase.java:659) at com.fasterxml.jackson.core.json.ReaderBasedJsonParser._handleOddValue(ReaderBasedJsonParser.java:2005) at com.fasterxml.jackson.core.json.ReaderBasedJsonParser.nextToken(ReaderBasedJsonParser.java:802) at com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:4761) at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4667) at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3629) at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3597) at org.apache.streampark.console.base.util.JacksonUtils.read(JacksonUtils.java:49) at org.apache.streampark.console.core.task.FlinkAppHttpWatcher.yarnRestRequest(FlinkAppHttpWatcher.java:802) 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)

[duguyue8]

解决