From 0551c1189d830494c26e0c339318686e7ca2f0d9 Mon Sep 17 00:00:00 2001 From: 54liuyao <54liuyao> Date: Thu, 25 Apr 2024 18:46:13 +0800 Subject: [PATCH] save stream tbname --- source/libs/stream/src/streamState.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c index 3928437ef8..52002b7ea8 100644 --- a/source/libs/stream/src/streamState.c +++ b/source/libs/stream/src/streamState.c @@ -1111,7 +1111,7 @@ int32_t streamStateGetParName(SStreamState* pState, int64_t groupId, void** pVal if (!pStr) { int32_t code = streamStateGetParName_rocksdb(pState, groupId, pVal); if (code == TSDB_CODE_SUCCESS) { - tSimpleHashPut(pState->parNameMap, &groupId, sizeof(int64_t), pVal, TSDB_TABLE_NAME_LEN); + tSimpleHashPut(pState->parNameMap, &groupId, sizeof(int64_t), *pVal, TSDB_TABLE_NAME_LEN); } return code; }