Some logs

src/backend/distributed/metadata/metadata_cache.c

@@ -4626,6 +4626,7 @@ InvalidateDistRelationCacheCallback(Datum argument, Oid relationId)
 		 */
 		if (relationId == MetadataCache.distPartitionRelationId)
 		{
+			elog(LOG, "NOOO: pg_dist_partition changed");
 			InvalidateMetadataSystemCache();
 		}
 
@@ -4774,6 +4775,7 @@ CreateDistObjectCache(void)
 void
 InvalidateMetadataSystemCache(void)
 {
+	elog(LOG, "INVALIDATING METADA SYSTEM CACHE");
 	InvalidateConnParamsHashEntries();
 
 	memset(&MetadataCache, 0, sizeof(MetadataCache));

src/backend/distributed/shared_library_init.c

@@ -664,6 +664,7 @@ StartupCitusBackend(void)
 	 * INVALID_CITUS_INTERNAL_BACKEND_GPID, since we override it again two
 	 * lines below.
 	 */
+	elog(LOG, "STARTUP CITUS BACKEND %s", application_name);
 	InitializeBackendData(INVALID_CITUS_INTERNAL_BACKEND_GPID);
 	AssignGlobalPID();
 	RegisterConnectionCleanup();

src/backend/distributed/sql/udfs/citus_isolation_test_session_is_blocked/11.2-1.sql

@@ -25,9 +25,9 @@ RETURNS boolean AS $$
     END IF;
 
     RAISE WARNING E'DETECTING BLOCKS FOR %', mBlockedGlobalPid;
-    FOR r IN select p.blocking_global_pid, a1.query blocking_query, p.waiting_global_pid, a2.query waiting_query from citus_internal_global_blocked_processes() p join pg_stat_activity a1 on p.blocking_pid = a1.pid join  pg_stat_activity a2 on p.waiting_pid = a2.pid
+    FOR r IN select p.blocking_global_pid, p.blocking_pid, a1.application_name blocking_app, a1.query blocking_query, p.waiting_global_pid, p.waiting_pid, a2.application_name waiting_app, a2.query waiting_query from citus_internal_global_blocked_processes() p join pg_stat_activity a1 on p.blocking_pid = a1.pid join  pg_stat_activity a2 on p.waiting_pid = a2.pid
     LOOP
-        RAISE WARNING E'GPID: % %\nBLOCKS\nGPID: % %', r.blocking_global_pid,  r.blocking_query, r.waiting_global_pid, r.waiting_query;
+        RAISE WARNING E'GPID: % % % %\nBLOCKS\nGPID: % % % %', r.blocking_global_pid, r.blocking_pid, r.blocking_app, r.blocking_query, r.waiting_global_pid, r.waiting_pid, r.waiting_app, r.waiting_query;
     END LOOP;
 
     IF current_setting('citus.isolation_test_check_all_blocks') = 'off' THEN

src/backend/distributed/transaction/backend_data.c

@@ -702,6 +702,8 @@ InitializeBackendData(const char *applicationName)
 	UnSetDistributedTransactionId();
 	UnSetGlobalPID();
 
+	elog(LOG, "INITIALIZE BACKEND DATA %lu", gpid);
+
 	SpinLockAcquire(&MyBackendData->mutex);
 	MyBackendData->distributedCommandOriginator = IsExternalClientBackend();
 	MyBackendData->globalPID = gpid;
@@ -749,6 +751,7 @@ UnSetGlobalPID(void)
 	/* backend does not exist if the extension is not created */
 	if (MyBackendData)
 	{
+		elog(LOG, "UNSETTING GLOBAL PID");
 		SpinLockAcquire(&MyBackendData->mutex);
 
 		MyBackendData->globalPID = 0;
@@ -888,6 +891,7 @@ AssignGlobalPID(void)
 		globalPID = ExtractGlobalPID(application_name);
 	}
 
+	elog(LOG, "ASSIGNING GLOBAL PID %lu", globalPID);
 	Oid userId = GetUserId();
 
 	SpinLockAcquire(&MyBackendData->mutex);