From b0b3cb9e5beeb337554b54aeb5b197d74f7b0cca Mon Sep 17 00:00:00 2001
From: Sait Talha Nisanci <s.talhanisanci@gmail.com>
Date: Tue, 19 May 2020 16:04:43 +0300
Subject: [PATCH] fix style

---
 src/backend/distributed/executor/citus_custom_scan.c     | 1 +
 src/backend/distributed/executor/multi_server_executor.c | 4 +++-
 src/backend/distributed/utils/task_execution_utils.c     | 5 +++--
 src/backend/distributed/worker/worker_merge_protocol.c   | 5 ++---
 src/include/distributed/multi_server_executor.h          | 1 -
 5 files changed, 9 insertions(+), 7 deletions(-)

diff --git a/src/backend/distributed/executor/citus_custom_scan.c b/src/backend/distributed/executor/citus_custom_scan.c
index 49ef3a2ab..a2586593f 100644
--- a/src/backend/distributed/executor/citus_custom_scan.c
+++ b/src/backend/distributed/executor/citus_custom_scan.c
@@ -556,6 +556,7 @@ AdaptiveExecutorCreateScan(CustomScan *scan)
 	return (Node *) scanState;
 }
 
+
 /*
  * CoordinatorInsertSelectCrateScan creates the scan state for executing
  * INSERT..SELECT into a distributed table via the coordinator.
diff --git a/src/backend/distributed/executor/multi_server_executor.c b/src/backend/distributed/executor/multi_server_executor.c
index 8da107eee..d03685211 100644
--- a/src/backend/distributed/executor/multi_server_executor.c
+++ b/src/backend/distributed/executor/multi_server_executor.c
@@ -114,7 +114,7 @@ JobExecutorType(DistributedPlan *distributedPlan)
 			if (HasReplicatedDistributedTable(distributedPlan->relationIdList))
 			{
 				ereport(ERROR, (errmsg(
-					"repartitioning with shard_replication_factor > 1 is not supported")));
+									"repartitioning with shard_replication_factor > 1 is not supported")));
 			}
 			return MULTI_EXECUTOR_ADAPTIVE;
 		}
@@ -164,6 +164,7 @@ HasReplicatedDistributedTable(List *relationOids)
 	return false;
 }
 
+
 /*
  * RemoveJobDirectory gets automatically called at portal drop (end of query) or
  * at transaction abort. The function removes the job directory and releases the
@@ -178,6 +179,7 @@ RemoveJobDirectory(uint64 jobId)
 	ResourceOwnerForgetJobDirectory(CurrentResourceOwner, jobId);
 }
 
+
 /*
  * CheckIfSizeLimitIsExceeded checks if the limit is exceeded by intermediate
  * results, if there is any.
diff --git a/src/backend/distributed/utils/task_execution_utils.c b/src/backend/distributed/utils/task_execution_utils.c
index 6694a11db..2507adf4f 100644
--- a/src/backend/distributed/utils/task_execution_utils.c
+++ b/src/backend/distributed/utils/task_execution_utils.c
@@ -53,7 +53,7 @@ typedef struct TaskMapEntry
 static HTAB * TaskHashCreate(uint32 taskHashSize);
 static Task * TaskHashEnter(HTAB *taskHash, Task *task);
 static Task * TaskHashLookup(HTAB *trackerHash, TaskType taskType, uint64 jobId,
-							 uint32 taskId);                             
+							 uint32 taskId);
 
 /*
  * TaskAndExecutionList visits all tasks in the job tree, starting with the given
@@ -129,6 +129,7 @@ TaskAndExecutionList(List *jobTaskList)
 	return taskAndExecutionList;
 }
 
+
 /*
  * TaskHashCreate allocates memory for a task hash, initializes an
  * empty hash, and returns this hash.
@@ -223,4 +224,4 @@ TaskHashLookup(HTAB *taskHash, TaskType taskType, uint64 jobId, uint32 taskId)
 	}
 
 	return task;
-}
\ No newline at end of file
+}
diff --git a/src/backend/distributed/worker/worker_merge_protocol.c b/src/backend/distributed/worker/worker_merge_protocol.c
index 7becd825d..da52354c5 100644
--- a/src/backend/distributed/worker/worker_merge_protocol.c
+++ b/src/backend/distributed/worker/worker_merge_protocol.c
@@ -54,8 +54,7 @@ static void CreateTaskTable(StringInfo schemaName, StringInfo relationName,
 							List *columnNameList, List *columnTypeList);
 static void CopyTaskFilesFromDirectory(StringInfo schemaName, StringInfo relationName,
 									   StringInfo sourceDirectoryName, Oid userId);
-static void
-CreateJobSchema(StringInfo schemaName, char *schemaOwner);
+static void CreateJobSchema(StringInfo schemaName, char *schemaOwner);
 
 
 /* exports for SQL callable functions */
@@ -89,6 +88,7 @@ worker_create_schema(PG_FUNCTION_ARGS)
 	PG_RETURN_VOID();
 }
 
+
 /*
  * CreateJobSchema creates a job schema with the given schema name. Note that
  * this function ensures that our pg_ prefixed schema names can be created.
@@ -141,7 +141,6 @@ CreateJobSchema(StringInfo schemaName, char *schemaOwner)
 }
 
 
-
 /*
  * worker_repartition_cleanup removes the job directory and schema with the given job id .
  */
diff --git a/src/include/distributed/multi_server_executor.h b/src/include/distributed/multi_server_executor.h
index 2b4195db8..e00fed303 100644
--- a/src/include/distributed/multi_server_executor.h
+++ b/src/include/distributed/multi_server_executor.h
@@ -31,7 +31,6 @@
 	");"
 
 
-
 /* Enumeration that represents distributed executor types */
 typedef enum
 {