From 0aa4df4c6dadc9bf9900953b23969b59ed6828ca Mon Sep 17 00:00:00 2001
From: zhangwh <zhangwh@vastdata.com.cn>
Date: Sun, 25 Jun 2023 17:57:24 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96SMP=E5=88=9B=E5=BB=BA?=
 =?UTF-8?q?=E5=B9=B6=E8=A1=8C=E7=BA=BF=E7=A8=8B=E5=A4=B1=E8=B4=A5=E6=97=B6?=
 =?UTF-8?q?=E7=9A=84=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/gausskernel/process/stream/streamCore.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/gausskernel/process/stream/streamCore.cpp b/src/gausskernel/process/stream/streamCore.cpp
index 9736c8b7d..40903ce83 100755
--- a/src/gausskernel/process/stream/streamCore.cpp
+++ b/src/gausskernel/process/stream/streamCore.cpp
@@ -744,7 +744,7 @@ const List* StreamNodeGroup::getStreamPairList()
 void StreamNodeGroup::initStreamThread(StreamProducer* producer, uint8 smpIdentifier, StreamPair* pair)
 {
     ThreadId producerThreadId = ApplyStreamThread(producer);
-    if (producerThreadId != 0) {
+    if (producerThreadId != 0 && producerThreadId != InvalidTid) {
 #ifdef __aarch64__
         pg_memory_barrier();
 #endif