diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index d2bbbfd8f8..4857bfa118 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -123,7 +123,7 @@ func NewRocksMQ(name string, idAllocator allocator.GIDAllocator) (*rocksmq, erro opts.SetBlockBasedTableFactory(bbto) opts.SetCreateIfMissing(true) opts.SetPrefixExtractor(gorocksdb.NewFixedPrefixTransform(FixedChannelNameLen + 1)) - opts.SetMaxOpenFiles(-1) + // opts.SetMaxOpenFiles(-1) db, err := gorocksdb.OpenDb(opts, name) if err != nil {