diff --git a/go/topology/topology.go b/go/topology/topology.go
index 1c55138e2..8c8a2223f 100644
--- a/go/topology/topology.go
+++ b/go/topology/topology.go
@@ -105,7 +105,7 @@ func (t *Topology) PickForWrite(repType storage.ReplicationType, count int) (str
 		t.replicaType2VolumeLayout[replicationTypeIndex] = NewVolumeLayout(repType, t.volumeSizeLimit, t.pulse)
 	}
 	vid, count, datanodes, err := t.replicaType2VolumeLayout[replicationTypeIndex].PickForWrite(count)
-	if err != nil {
+	if err != nil || datanodes.Length() == 0 {
 		return "", 0, nil, errors.New("No writable volumes avalable!")
 	}
 	fileId, count := t.sequence.NextFileId(count)