这不很清楚么,连 192.168.0.32:9866 超时啊
在 2021-08-20 18:13:10,"杨帅统" <itcc...@163.com> 写道: >// 开启checkpoint >env.enableCheckpointing(5000L, CheckpointingMode.EXACTLY_ONCE); > >env.getCheckpointConfig().setCheckpointStorage("hdfs://test.gl.cdh.node1:8020/flink/flink-cdc-demo"); >System.setProperty("HADOOP_USER_NAME", "root"); > > >报错信息如下: >org.apache.hadoop.net.ConnectTimeoutException: 60000 millis timeout while >waiting for channel to be ready for connect. ch : >java.nio.channels.SocketChannel[connection-pending remote=/192.168.0.32:9866] >at org.apache.hadoop.net.NetUtils.connect(NetUtils.java:534) >at >org.apache.hadoop.hdfs.DataStreamer.createSocketForPipeline(DataStreamer.java:253) >at >org.apache.hadoop.hdfs.DataStreamer.createBlockOutputStream(DataStreamer.java:1725) >at >org.apache.hadoop.hdfs.DataStreamer.nextBlockOutputStream(DataStreamer.java:1679) >at org.apache.hadoop.hdfs.DataStreamer.run(DataStreamer.java:716) >2021-08-20 18:11:49 WARN DataStreamer:1683 - Abandoning >BP-1233461189-192.168.0.27-1615278916172:blk_1074013541_272740 >2021-08-20 18:11:50 WARN DataStreamer:1688 - Excluding datanode >DatanodeInfoWithStorage[192.168.0.32:9866,DS-f45126b3-f020-473f-b25f-1b37f8540eb7,DISK] >2021-08-20 18:11:50 WARN DataStreamer:826 - DataStreamer Exception >org.apache.hadoop.ipc.RemoteException(java.io.IOException): File >/flink/flink-cdc-demo/13714486ceb74d650ba104df7b202920/chk-1/_metadata could >only be written to 0 of the 1 minReplication nodes. There are 3 datanode(s) >running and 3 node(s) are excluded in this operation. >at >org.apache.hadoop.hdfs.server.blockmanagement.BlockManager.chooseTarget4NewBlock(BlockManager.java:2102) >at >org.apache.hadoop.hdfs.server.namenode.FSDirWriteFileOp.chooseTargetForNewBlock(FSDirWriteFileOp.java:294) >at >org.apache.hadoop.hdfs.server.namenode.FSNamesystem.getAdditionalBlock(FSNamesystem.java:2673)