这不很清楚么，连 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)
