From 6cc3b5da0e3a78dc3dbdfa029fbcf6c38912d766 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 23 Jan 2025 13:37:41 +0800 Subject: [PATCH] fix(stream): add upper bound for the time of waiting for creating table. --- source/dnode/vnode/src/tq/tqSink.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tqSink.c b/source/dnode/vnode/src/tq/tqSink.c index 77d80269e6..1b2ff8cb57 100644 --- a/source/dnode/vnode/src/tq/tqSink.c +++ b/source/dnode/vnode/src/tq/tqSink.c @@ -861,7 +861,7 @@ int32_t doWaitForDstTableCreated(SVnode* pVnode, SStreamTask* pTask, STableSinkI int32_t vgId = TD_VID(pVnode); int64_t suid = pTask->outputInfo.tbSink.stbUid; const char* id = pTask->id.idStr; - int32_t timeout = 600; // 10min + int32_t timeout = 300; // 5min int64_t start = taosGetTimestampSec(); while (pTableSinkInfo->uid == 0) {