reset database oid at end of SQL task

2022-08-06 23:20:44 +08:00
parent 8ec5d33e36
commit 00a1769c17
1 changed files with 3 additions and 0 deletions
--- 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.