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