From 7c9d24cbb753c5224b8f0af9818e5de87417feaf Mon Sep 17 00:00:00 2001 From: Xiaofan <83447078+xiaofan-luan@users.noreply.github.com> Date: Tue, 31 Oct 2023 00:44:14 +0800 Subject: [PATCH] Remove Properties in rocksmq (#28000) Signed-off-by: xiaofan-luan --- internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go b/internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go index 38c0bc8140..7f52cdf66d 100644 --- a/internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go +++ b/internal/mq/mqimpl/rocksmq/server/rocksmq_impl.go @@ -225,8 +225,8 @@ func NewRocksMQ(name string, idAllocator allocator.Interface) (*rocksmq, error) // db, err := gorocksdb.OpenDb(opts, name) // use properties as the column families to store trace id - giveColumnFamilies := []string{"default", "properties"} - db, cfHandles, err := gorocksdb.OpenDbColumnFamilies(optsStore, name, giveColumnFamilies, []*gorocksdb.Options{optsStore, optsStore}) + giveColumnFamilies := []string{"default"} + db, cfHandles, err := gorocksdb.OpenDbColumnFamilies(optsStore, name, giveColumnFamilies, []*gorocksdb.Options{optsStore}) if err != nil { return nil, err }