GitHub user duguyue8 edited a discussion: 跑flinksql的demo时正常，换成kafka source时总是报错
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)"<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01//EN" "http://www.w3.org/TR/html4/strict.dtd";> <html> <meta http-equiv="X-UA-Compatible" content="IE=8"> <meta http-equiv="Content-type" content="text/html; charset=UTF-8"> <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) 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]
