From 00a1769c177b20d260f900e1d502a3b95f26ba84 Mon Sep 17 00:00:00 2001
From: junhangis <xieweiping@xfusion.com>
Date: Sat, 6 Aug 2022 23:20:44 +0800
Subject: [PATCH] reset database oid at end of SQL task

---
 src/gausskernel/process/threadpool/threadpool_stream.cpp | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/gausskernel/process/threadpool/threadpool_stream.cpp b/src/gausskernel/process/threadpool/threadpool_stream.cpp
index d87c00fc2..44234a822 100644
--- a/src/gausskernel/process/threadpool/threadpool_stream.cpp
+++ b/src/gausskernel/process/threadpool/threadpool_stream.cpp
@@ -192,6 +192,9 @@ static void ResetStreamStatus()
         pfree_ext(t_thrd.log_cxt.msgbuf->data);
     }
 
+    t_thrd.proc->databaseId = InvalidOid;
+    t_thrd.proc->roleId = InvalidOid;
+
     /*
      * Reset extended-query-message flag, so that any errors
      * encountered in "idle" state don't provoke skip.