diff --git a/src/backend/distributed/utils/citus_copyfuncs.c b/src/backend/distributed/utils/citus_copyfuncs.c index e3a3f5875..31976b406 100644 --- a/src/backend/distributed/utils/citus_copyfuncs.c +++ b/src/backend/distributed/utils/citus_copyfuncs.c @@ -269,6 +269,7 @@ CopyNodeTaskExecution(COPYFUNC_ARGS) COPY_SCALAR_FIELD(currentNodeIndex); COPY_SCALAR_FIELD(querySourceNodeIndex); COPY_SCALAR_FIELD(failureCount); + COPY_SCALAR_FIELD(criticalErrorOccurred); } diff --git a/src/backend/distributed/utils/citus_outfuncs.c b/src/backend/distributed/utils/citus_outfuncs.c index 45709aafe..5e46bf63b 100644 --- a/src/backend/distributed/utils/citus_outfuncs.c +++ b/src/backend/distributed/utils/citus_outfuncs.c @@ -479,6 +479,7 @@ OutTaskExecution(OUTFUNC_ARGS) WRITE_UINT_FIELD(currentNodeIndex); WRITE_UINT_FIELD(querySourceNodeIndex); WRITE_UINT_FIELD(failureCount); + WRITE_BOOL_FIELD(criticalErrorOccurred); }