diff --git a/transport/ray/direct.go b/transport/ray/direct.go index ff88127b..c08e5a9a 100644 --- a/transport/ray/direct.go +++ b/transport/ray/direct.go @@ -48,7 +48,7 @@ func init() { if len(sizeStr) > 0 { customSize, err := strconv.ParseUint(sizeStr, 10, 32) if err == nil { - streamSizeLimit = uint64(customSize) * 1024 * 1024 + streamSizeLimit = customSize * 1024 * 1024 } } }