From c6ba2ca20568ec5f943660bcb7c271b091f98645 Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Wed, 18 Oct 2023 14:49:12 +0800
Subject: [PATCH] fix transfer crash

---
 source/libs/stream/src/streamBackendRocksdb.c | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index d1ddd5c81a..6b0275f44e 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -433,6 +433,7 @@ int32_t rebuildDirFromCheckpoint(const char* path, int64_t chkpId, char** dst) {
       }
       taosMkDir(state);
       code = copyFiles(chkp, state);
+      qInfo("copy snap file from %s to %s", chkp, state);
       if (code != 0) {
         qError("failed to restart stream backend from %s, reason: %s", chkp, tstrerror(TAOS_SYSTEM_ERROR(errno)));
       } else {
@@ -508,6 +509,7 @@ int32_t rebuildDirFromChkp2(const char* path, char* key, int64_t chkpId, char**
       }
       taosMkDir(defaultPath);
       code = copyFiles(chkpPath, defaultPath);
+      qInfo("copy snap file from %s to %s", chkpPath, defaultPath);
       if (code != 0) {
         qError("failed to restart stream backend from %s, reason: %s", chkpPath, tstrerror(TAOS_SYSTEM_ERROR(errno)));
       } else {
@@ -1805,6 +1807,7 @@ STaskDbWrapper* taskDbOpen(char* path, char* key, int64_t chkpId) {
 
   cfNames = rocksdb_list_column_families(pTaskDb->dbOpt, dbPath, &nCf, &err);
   if (nCf == 0) {
+    qInfo("newly create db, need to restart");
     // pre create db
     pTaskDb->db = rocksdb_open(pTaskDb->pCfOpts[0], dbPath, &err);
     rocksdb_close(pTaskDb->db);