Bad connect ack with firstBadLink 192.168.*.*:50010

// connects to the first datanode in the pipeline  

  // Returns true if success, otherwise return failure.  

  //  

  private boolean createBlockOutputStream(DatanodeInfo[] nodes, String client,  

                  boolean recoveryFlag) {  

    String firstBadLink = "";  

    if (LOG.isDebugEnabled()) {  

      for (int i = 0; i < nodes.length; i++) {  

        LOG.debug("pipeline = " + nodes[i].getName());  

      }  

    }  

    // persist blocks on namenode on next flush  

    persistBlocks = true;  

    try {  

      LOG.debug("Connecting to " + nodes[0].getName());  

      InetSocketAddress target = NetUtils.createSocketAddr(nodes[0].getName());  

      s = socketFactory.createSocket();  

      int timeoutValue = 3000 * nodes.length + socketTimeout;  

      NetUtils.connect(s, target, timeoutValue);  

      s.setSoTimeout(timeoutValue);  

      s.setSendBufferSize(DEFAULT_DATA_SOCKET_SIZE);  

      LOG.debug("Send buf size " + s.getSendBufferSize());  

      long writeTimeout = HdfsConstants.WRITE_TIMEOUT_EXTENSION * nodes.length +  

                          datanodeWriteTimeout;  

      //  

      // Xmit header info to datanode  

      //  

      DataOutputStream out = new DataOutputStream(  

          new BufferedOutputStream(NetUtils.getOutputStream(s, writeTimeout),   

                                   DataNode.SMALL_BUFFER_SIZE));  

      blockReplyStream = new DataInputStream(NetUtils.getInputStream(s));  

      out.writeShort( DataTransferProtocol.DATA_TRANSFER_VERSION );  

      out.write( DataTransferProtocol.OP_WRITE_BLOCK );  

      out.writeLong( block.getBlockId() );  

      out.writeLong( block.getGenerationStamp() );  

      out.writeInt( nodes.length );  

      out.writeBoolean( recoveryFlag );       // recovery flag  

      Text.writeString( out, client );  

      out.writeBoolean(false); // Not sending src node information  

      out.writeInt( nodes.length - 1 );  

      for (int i = 1; i < nodes.length; i++) {  

        nodes[i].write(out);  

      }  

      checksum.writeHeader( out );  

      out.flush();  

      // receive ack for connect  

      firstBadLink = Text.readString(blockReplyStream);  

      if (firstBadLink.length() != 0) {  

        throw new IOException("Bad connect ack with firstBadLink " + firstBadLink);  

      }  

      blockStream = out;  

      return true;     // success  

    } catch (IOException ie) {