postgres
diff --git a/‎contrib/pg_stat_statements/pg_stat_statements.c
Copy file name to clipboardExpand all lines: contrib/pg_stat_statements/pg_stat_statements.c
+3-1Lines changed: 3 additions & 1 deletion b/‎contrib/pg_stat_statements/pg_stat_statements.c
Copy file name to clipboardExpand all lines: contrib/pg_stat_statements/pg_stat_statements.c
+3-1Lines changed: 3 additions & 1 deletion
diff --git a/‎src/backend/executor/execParallel.c
Copy file name to clipboardExpand all lines: src/backend/executor/execParallel.c
-1Lines changed: 0 additions & 1 deletion b/‎src/backend/executor/execParallel.c
Copy file name to clipboardExpand all lines: src/backend/executor/execParallel.c
-1Lines changed: 0 additions & 1 deletion
diff --git a/‎src/backend/utils/adt/pgstatfuncs.c
Copy file name to clipboardExpand all lines: src/backend/utils/adt/pgstatfuncs.c
+1-1Lines changed: 1 addition & 1 deletion b/‎src/backend/utils/adt/pgstatfuncs.c
Copy file name to clipboardExpand all lines: src/backend/utils/adt/pgstatfuncs.c
+1-1Lines changed: 1 addition & 1 deletion
@@ -47,6 +47,7 @@
 #include <sys/stat.h>
 #include <unistd.h>
 
+#include "access/parallel.h"
 #include "catalog/pg_authid.h"
 #include "common/hashfn.h"
 #include "executor/instrument.h"
@@ -278,8 +279,9 @@ static bool pgss_save;			/* whether to save stats across shutdown */
 
 
 #define pgss_enabled(level) \
+	(!IsParallelWorker() && \
 	(pgss_track == PGSS_TRACK_ALL || \
-	(pgss_track == PGSS_TRACK_TOP && (level) == 0))
+	(pgss_track == PGSS_TRACK_TOP && (level) == 0)))
 
 #define record_gc_qtexts() \
 	do { \
 
@@ -1426,7 +1426,6 @@ ParallelQueryMain(dsm_segment *seg, shm_toc *toc)
 
 	/* Report workers' query and queryId for monitoring purposes */
 	pgstat_report_activity(STATE_RUNNING, debug_query_string);
-	pgstat_report_queryid(queryDesc->plannedstmt->queryId, false);
 
 	/* Attach to the dynamic shared memory area. */
 	area_space = shm_toc_lookup(toc, PARALLEL_KEY_DSA, false);
 
@@ -917,7 +917,7 @@ pg_stat_get_activity(PG_FUNCTION_ARGS)
 			if (beentry->st_queryid == 0)
 				nulls[29] = true;
 			else
-				values[29] = DatumGetUInt64(beentry->st_queryid);
+				values[29] = UInt64GetDatum(beentry->st_queryid);
 		}
 		else
 		{
Original file line number	Diff line number	Diff line change
`@@ -917,7 +917,7 @@ pg_stat_get_activity(PG_FUNCTION_ARGS)`
`917`	`917`	`if (beentry->st_queryid == 0)`
`918`	`918`	`nulls[29] = true;`
`919`	`919`	`else`
`920`		`- values[29] = DatumGetUInt64(beentry->st_queryid);`
	`920`	`+ values[29] = UInt64GetDatum(beentry->st_queryid);`
`921`	`921`	`}`
`922`	`922`	`else`
`923`	`923`	`{`