mirror of https://github.com/milvus-io/milvus.git
fix: [Cherry-pick]Remove SetFinalizer which cause proxy msgstream memory leak (#29404)
relate: https://github.com/milvus-io/milvus/issues/28367 pr: https://github.com/milvus-io/milvus/pull/29403 Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>pull/29452/head
parent
60a90463d0
commit
2256b53e03
|
@ -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