From 77261068e0a41c204107685030eb6279e1765122 Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Thu, 16 Nov 2023 11:06:55 +0800
Subject: [PATCH] fix stream backend convert

---
 include/libs/stream/tstream.h                 | 2 +-
 source/libs/stream/src/streamBackendRocksdb.c | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/include/libs/stream/tstream.h b/include/libs/stream/tstream.h
index 337b760cf4..4979a576a7 100644
--- a/include/libs/stream/tstream.h
+++ b/include/libs/stream/tstream.h
@@ -59,7 +59,7 @@ typedef struct SStreamTask   SStreamTask;
 typedef struct SStreamQueue  SStreamQueue;
 typedef struct SStreamTaskSM SStreamTaskSM;
 
-#define SSTREAM_TASK_VER              3
+#define SSTREAM_TASK_VER              2
 #define SSTREAM_TASK_INCOMPATIBLE_VER 1
 #define SSTREAM_TASK_NEED_CONVERT_VER 2
 
diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 4e71eff431..f9bd5476e7 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -1759,7 +1759,7 @@ int32_t taskDbOpenCfByKey(STaskDbWrapper* pDb, const char* key) {
 
   rocksdb_column_family_handle_t* cf =
       rocksdb_create_column_family(pDb->db, pDb->pCfOpts[idx], ginitDict[idx].key, &err);
-  if (err != NULL) {
+  if (idx != 0 && err != NULL) {
     stError("failed to open cf, key:%s, reason: %s", key, err);
     taosMemoryFree(err);
     code = -1;