From a720929a8bc11286278943555639dd0783553c8d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Philip=20Dub=C3=A9?= <gunkmute@gmail.com>
Date: Wed, 16 Oct 2019 21:00:38 +0000
Subject: [PATCH] Remove print debugging

---
 src/backend/distributed/commands/function.c          | 12 ------------
 .../distributed/planner/multi_logical_optimizer.c    |  2 --
 2 files changed, 14 deletions(-)

diff --git a/src/backend/distributed/commands/function.c b/src/backend/distributed/commands/function.c
index a82770f69..656dfda28 100644
--- a/src/backend/distributed/commands/function.c
+++ b/src/backend/distributed/commands/function.c
@@ -239,7 +239,6 @@ mark_aggregate_for_distributed_execution(PG_FUNCTION_ARGS)
 	int numargs = 0;
 	Oid *argtypes = NULL;
 
-	elog(WARNING, "prelude");
 
 	if (!HeapTupleIsValid(proctup))
 	{
@@ -259,8 +258,6 @@ mark_aggregate_for_distributed_execution(PG_FUNCTION_ARGS)
 	}
 	agg = (Form_pg_aggregate) GETSTRUCT(aggtup);
 
-	elog(WARNING, "begins");
-
 	initStringInfo(&helperSuffix);
 	appendStringInfoAggregateHelperSuffix(&helperSuffix, proc, agg);
 
@@ -270,8 +267,6 @@ mark_aggregate_for_distributed_execution(PG_FUNCTION_ARGS)
 					 helperSuffix.data);
 	helperOid = CoordCombineAggOid(helperName.data);
 
-	elog(WARNING, "helperOid %d", helperOid);
-
 	if (helperOid == InvalidOid)
 	{
 		Oid coordArgTypes[2] = { BYTEAOID, ANYELEMENTOID };
@@ -340,8 +335,6 @@ mark_aggregate_for_distributed_execution(PG_FUNCTION_ARGS)
 							  numargs, argtypes, false);
 	}
 
-	elog(WARNING, "mark em");
-
 	/* set strategy column value */
 	UpdateDistObjectAggregationStrategy(funcOid, AGGREGATION_STRATEGY_COMBINE);
 
@@ -575,7 +568,6 @@ CreateAggregateHelper(const char *helperName, const char *helperPrefix,
 
 	appendStringInfoChar(&command, ')');
 
-	elog(WARNING, "SEND %s", command.data);
 	SendCommandToWorkers(ALL_WORKERS, command.data);
 
 	/* TODO execute as CitusExtensionOwner */
@@ -589,8 +581,6 @@ CreateAggregateHelper(const char *helperName, const char *helperPrefix,
 	}
 	SPI_finish();
 
-	elog(WARNING, "SENT");
-
 	pfree(command.data);
 }
 
@@ -891,8 +881,6 @@ UpdateDistObjectAggregationStrategy(Oid funcOid, int aggregationStrategy)
 	systable_endscan(scanDescriptor);
 
 	heap_close(pgDistObjectRel, NoLock);
-
-	elog(WARNING, "marked %d %d", funcOid, aggregationStrategy);
 }
 
 
diff --git a/src/backend/distributed/planner/multi_logical_optimizer.c b/src/backend/distributed/planner/multi_logical_optimizer.c
index bc4117684..5bd0aea30 100644
--- a/src/backend/distributed/planner/multi_logical_optimizer.c
+++ b/src/backend/distributed/planner/multi_logical_optimizer.c
@@ -1854,7 +1854,6 @@ MasterAggregateExpression(Aggref *originalAggregate,
 								   ObjectIdGetDatum(originalAggregate->aggfnoid));
 		if (!HeapTupleIsValid(aggTuple))
 		{
-			elog(WARNING, "!@#");
 			elog(WARNING, "citus cache lookup failed for aggregate %u",
 				 originalAggregate->aggfnoid);
 			combine = InvalidOid;
@@ -2939,7 +2938,6 @@ WorkerAggregateExpressionList(Aggref *originalAggregate,
 								   ObjectIdGetDatum(originalAggregate->aggfnoid));
 		if (!HeapTupleIsValid(aggTuple))
 		{
-			elog(WARNING, "!3434");
 			elog(WARNING, "citus cache lookup failed for aggregate %u",
 				 originalAggregate->aggfnoid);
 			combine = InvalidOid;