在向flink的网页中提交一个任务，点击Show Plan出现如下错误：
进入linux查看日志信息：
cat flink-fei-standalonesession-0-hadoop102.log.1
2022-03-27 01:00:56,287 WARN akka.remote.ReliableDeliverySupervisor [] - Association with remote system [akka.tcp://flink@192.168.10.103:38496] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@192.168.10.103:38496]] Caused by: [java.net.ConnectException: 拒绝连接: /192.168.10.103:38496]
2022-03-27 01:00:57,803 WARN akka.remote.ReliableDeliverySupervisor [] - Association with remote system [akka.tcp://flink@192.168.10.104:43792] has failed, address is now gated for [50] ms. Reason: [Disassociated]
2022-03-27 01:00:57,804 WARN akka.remote.ReliableDeliverySupervisor [] - Association with remote system [akka.tcp://flink-metrics@192.168.10.104:43949] has failed, address is now gated for [50] ms. Reason: [Disassociated]
2022-03-27 01:00:58,754 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - RECEIVED SIGNAL 15: SIGTERM. Shutting down as requested.
2022-03-27 01:00:58,769 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Shutting StandaloneSessionClusterEntrypoint down with application status UNKNOWN. Diagnostics Cluster entrypoint has been closed externally..
2022-03-27 01:00:58,778 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Shutting down rest endpoint.
2022-03-27 01:00:58,780 INFO org.apache.flink.runtime.blob.BlobServer [] - Stopped BLOB server at 0.0.0.0:45143
2022-03-27 01:00:59,096 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting down remote daemon.
2022-03-27 01:00:59,096 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote daemon shut down; proceeding with flushing remote transports.
2022-03-27 01:00:59,097 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting down remote daemon.
2022-03-27 01:00:59,115 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote daemon shut down; proceeding with flushing remote transports.
2022-03-27 01:00:59,144 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting shut down.
2022-03-27 01:00:59,152 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting shut down.
通过观察是拒绝连接，回到代码中看到原来实在监听一个端口输入的数据造成的错误
//从参数中提取主机名和端口号
ParameterTool parameterTool = ParameterTool.fromArgs(args);
String hostName = parameterTool.get("host");
Integer port = parameterTool.getInt("port");
//读取文本流
DataStreamSource lineDataStream = env.socketTextStream(hostName, port);
由于还是实验阶段，并没有真正的通过监听端口获取数据来计算，这里采用给定一个地址和端口号的方式来实现。即如下方式来实现：
DataStreamSourcelineDataStream = env.socketTextStream("hadoop102", 7777);
重新编译并打包，将达成的jar包上传到flink的网页中。
将该填的信息填好，点击Show Plan弹出下面的页面：
下一步点击Submit提交任务执行，又出现错误：
通过查看异常信息知道：
出现上面异常的原因是在linux上还没有执行如下命令：
nc -lk 7777
在hadoop102的虚拟机上执行上面的一行命令，之后重新提交一次任务
这下能够正常运行了，之后在linux中输入一行数据，测试程序是否好用。
linux输入一行数据用“ ”隔开
程序正在运行：
在TaskManager中查看执行结果
从上面可以看到任务实在在个节点上运行的，这也是符合集群运行的特点的。
