diff --git a/transport/ray/direct.go b/transport/ray/direct.go
index 2d4b6dfe..e208fd32 100644
--- a/transport/ray/direct.go
+++ b/transport/ray/direct.go
@@ -97,7 +97,7 @@ func (this *Stream) TryWriteOnce(data *alloc.Buffer) error {
 	select {
 	case this.buffer <- data:
 		return nil
-	case <-time.After(16 * time.Second):
+	case <-time.After(2 * time.Second):
 		return ErrorIOTimeout
 	}
 }