From 966f01fad34e05fb000d269bc884b412e55301b3 Mon Sep 17 00:00:00 2001
From: Hadi Moshayedi <hadi@citusdata.com>
Date: Mon, 23 Apr 2018 09:07:52 -0400
Subject: [PATCH] Fix write and copy functions for TaskExecution. (#2120)

We were missing criticalErrorOccurred from CopyNodeTaskExecution() and OutTaskExecution(). This PR fixes it.
---
 src/backend/distributed/utils/citus_copyfuncs.c | 1 +
 src/backend/distributed/utils/citus_outfuncs.c  | 1 +
 2 files changed, 2 insertions(+)

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);
 }