diff --git a/src/gausskernel/process/threadpool/knl_session.cpp b/src/gausskernel/process/threadpool/knl_session.cpp index 2a22964f8..f7185179f 100755 --- a/src/gausskernel/process/threadpool/knl_session.cpp +++ b/src/gausskernel/process/threadpool/knl_session.cpp @@ -1416,6 +1416,9 @@ static void knl_u_spq_init(knl_u_spq_context* spq_cxt) spq_cxt->spq_opt_initialized = false; spq_cxt->remoteQuerys = NIL; spq_cxt->snapshot = (SnapshotData*)palloc0(sizeof(SnapshotData)); + spq_cxt->mdcache_invalidation_counter_registered = false; + spq_cxt->mdcache_invalidation_counter = 0; + spq_cxt->last_mdcache_invalidation_counter = 0; } #endif diff --git a/src/include/knl/knl_session.h b/src/include/knl/knl_session.h index e672b35f9..764ed6b12 100644 --- a/src/include/knl/knl_session.h +++ b/src/include/knl/knl_session.h @@ -2753,6 +2753,9 @@ typedef struct knl_u_spq_context { spqos::CWorkerPoolManager* m_worker_pool_manager; /* mdcache */ spqos::CCache *m_pcache; + bool mdcache_invalidation_counter_registered; + int64 mdcache_invalidation_counter; + int64 last_mdcache_invalidation_counter; /* cache factory */ spqos::CCacheFactory* m_factory; spqos::CMessageRepository *m_repository;