mirror of https://github.com/milvus-io/milvus.git
fix: Remove SetFinalizer which cause proxy msgstream memory leak (#29403)
relate: https://github.com/milvus-io/milvus/issues/28367 Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>pull/29442/head
parent
13988cbde7
commit
7c916b1035
|
@ -19,7 +19,6 @@ package proxy
|
|||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"runtime"
|
||||
"strconv"
|
||||
"sync"
|
||||
|
||||
|
@ -187,10 +186,6 @@ func createStream(factory msgstream.Factory, pchans []pChan, repack repackFuncTy
|
|||
if repack != nil {
|
||||
stream.SetRepackFunc(repack)
|
||||
}
|
||||
runtime.SetFinalizer(stream, func(stream msgstream.MsgStream) {
|
||||
stream.Close()
|
||||
})
|
||||
|
||||
return stream, nil
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue