提交flink 任务报错
Exception: Connection refused: localhost/127.0.0.1:8081
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:943)
at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
... 16 more
Caused by: org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:8081
错误的原因：没有启动flink
启动flink ./bin/start-cluster.sh
提交flink 任务报错Exception: Connection refused: localhost/127.0.0.1:8081 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ...
写了一个程序，用于连接网，检查或者更新当前软件的版本，用Junit测试本地服务，但是报了如下
异常
:java.net.ConnectException:
localhost
/
127.0
.
0.1
:8080 -
Connection
ref
u
sed
采用逐行输出的方式，最终确定是错在下面的几行代码，最主要的原因是网络连接问题
URL url = new URL(path);
【日常Exception】第二十五回：
Flink
启动job时报错，AbstractChannel$AnnotatedConnectException:
Connection
ref
u
sed
.....
Cau
sed
by: org.apache.
flink
.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection
ref
u
sed
: /0.0.0.0:9905
Cau
sed
by: java.net.ConnectException:
Connection
r...
启动
flink
sql client报错
[chb@test1
flink
-1.12.1]$ ./bin/sql-client.sh embedded
Setting HBASE_CONF_DIR=/etc/hbase/conf because no HBASE_CONF_DIR was set.
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/opt/
flink
-1.12.1/li
org.apache.
flink
.client.program.ProgramInvocationException: The main method cau
sed
an error: Failed to fetch next result
at org.apache.
flink
.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:366)
at org.apach...
网友问了一个问题。
flink
报错这个，我一看就知道是
flink
使用prometheus推送数据的时候，推送不上去，然后
拒绝
了。
是
flink
连接不上prometheus。但是网友陷入误区了，他没有使用prometheus，怎么会推送呢，所以很迷茫。
然后我让他 ，检测一下是否配置了，没有就不要加这个jar。
他去掉这个jar还是报错
后来让他看看配置发现了原因。配置中配置了如下
注释掉就好了。
03-20 13:56:19.120 382-393/? W/System.err: java.net.ConnectException:
localhost
/
127.0
.
0.1
:8080 -
Connection
ref
u
sed
03-20 13:56:19.170 382-393/? W/System.err: at org.apache.harmony.luni.net.Plain
学习
Flink
时，java程序启动报错：Cau
sed
by: java.net.ConnectException:
Connection
ref
u
sed
: connect
报错为连接
异常
，检查错位为端口未启动，没有数据，应该先启动端口，
启动后再运行java程序，问题解决。
附上java程序：
public class
Flink
WordCountJobWithAnonymous {
public static void main(String[] args) throws Excepti
平时为了做些安卓测试，我也会写一下后端的东西。已经有好长一段时间没写过服务端相关的内容了，今天看着郭霖的《第一行代码》，我把一个xml资源部署到了tomcat服务器上，在浏览器上是可以打开
http://
localhost
:
8081
/test/get_data.xml
这个地址进行访问的，但是在AS里面使用这个地址却报了如下的序错误（删减了部分错误内容）：
java.net.ConnectException: Failed to connect to
localhost
/
127.0
.
0.1
:
8081
一个环境并行度为1不会报错，但是并行度超过1 就会报错如下
Cau
sed
by: org.apache.
flink
.runtime.io.network.netty.exception.LocalTransportException: Sending the partition request to 'null' failed.
at org.apache.
flink
.runtime.io.network.netty.NettyPartitionRequestClient$1.operatio.
./bin/
flink
run examples/streaming/SocketWindowWordCount.jar --port 9000
第二个原因：端口号最好换一个，如果配置了连接hdfs的话
第三个原因：其实因为你配置了hdfs环境的原因，仔细想想，你是不是修改了
vim conf/
flink
-c...
