GitHub user duguyue8 added a comment to the discussion: Flink 1.18 FlinkSQL
jobs consistently report `java.net.ConnectException: yarnUtils restRequest
error, url: xxx` when reading from or writing to Kafka.
streampark2.1.6版本
补充错误信息：
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#discussioncomment-14324951
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
