external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove print debugging

fix_120_custom_aggregates_distribute_multiarg
Philip Dubé 2019-10-16 21:00:38 +00:00
parent f5b038e2bc
commit a720929a8b
2 changed files with 0 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/backend/distributed/commands/function.c
View File

@ -239,7 +239,6 @@ mark_aggregate_for_distributed_execution(PG_FUNCTION_ARGS)
int numargs = 0; int numargs = 0;
Oid *argtypes = NULL; Oid *argtypes = NULL;
elog(WARNING, "prelude");
if (!HeapTupleIsValid(proctup)) if (!HeapTupleIsValid(proctup))
{ {
@ -259,8 +258,6 @@ mark_aggregate_for_distributed_execution(PG_FUNCTION_ARGS)
} }
agg = (Form_pg_aggregate) GETSTRUCT(aggtup); agg = (Form_pg_aggregate) GETSTRUCT(aggtup);
elog(WARNING, "begins");
initStringInfo(&helperSuffix); initStringInfo(&helperSuffix);
appendStringInfoAggregateHelperSuffix(&helperSuffix, proc, agg); appendStringInfoAggregateHelperSuffix(&helperSuffix, proc, agg);
@ -270,8 +267,6 @@ mark_aggregate_for_distributed_execution(PG_FUNCTION_ARGS)
helperSuffix.data); helperSuffix.data);
helperOid = CoordCombineAggOid(helperName.data); helperOid = CoordCombineAggOid(helperName.data);
elog(WARNING, "helperOid %d", helperOid);
if (helperOid == InvalidOid) if (helperOid == InvalidOid)
{ {
Oid coordArgTypes[2] = { BYTEAOID, ANYELEMENTOID }; Oid coordArgTypes[2] = { BYTEAOID, ANYELEMENTOID };
@ -340,8 +335,6 @@ mark_aggregate_for_distributed_execution(PG_FUNCTION_ARGS)
numargs, argtypes, false); numargs, argtypes, false);
} }
elog(WARNING, "mark em");
/* set strategy column value */ /* set strategy column value */
UpdateDistObjectAggregationStrategy(funcOid, AGGREGATION_STRATEGY_COMBINE); UpdateDistObjectAggregationStrategy(funcOid, AGGREGATION_STRATEGY_COMBINE);
@ -575,7 +568,6 @@ CreateAggregateHelper(const char *helperName, const char *helperPrefix,
appendStringInfoChar(&command, ')'); appendStringInfoChar(&command, ')');
elog(WARNING, "SEND %s", command.data);
SendCommandToWorkers(ALL_WORKERS, command.data); SendCommandToWorkers(ALL_WORKERS, command.data);
/* TODO execute as CitusExtensionOwner */ /* TODO execute as CitusExtensionOwner */
@ -589,8 +581,6 @@ CreateAggregateHelper(const char *helperName, const char *helperPrefix,
} }
SPI_finish(); SPI_finish();
elog(WARNING, "SENT");
pfree(command.data); pfree(command.data);
} }
@ -891,8 +881,6 @@ UpdateDistObjectAggregationStrategy(Oid funcOid, int aggregationStrategy)
systable_endscan(scanDescriptor); systable_endscan(scanDescriptor);
heap_close(pgDistObjectRel, NoLock); heap_close(pgDistObjectRel, NoLock);
elog(WARNING, "marked %d %d", funcOid, aggregationStrategy);
} }

2
src/backend/distributed/planner/multi_logical_optimizer.c
View File

@ -1854,7 +1854,6 @@ MasterAggregateExpression(Aggref *originalAggregate,
ObjectIdGetDatum(originalAggregate->aggfnoid)); ObjectIdGetDatum(originalAggregate->aggfnoid));
if (!HeapTupleIsValid(aggTuple)) if (!HeapTupleIsValid(aggTuple))
{ {
elog(WARNING, "!@#");
elog(WARNING, "citus cache lookup failed for aggregate %u", elog(WARNING, "citus cache lookup failed for aggregate %u",
originalAggregate->aggfnoid); originalAggregate->aggfnoid);
combine = InvalidOid; combine = InvalidOid;
@ -2939,7 +2938,6 @@ WorkerAggregateExpressionList(Aggref *originalAggregate,
ObjectIdGetDatum(originalAggregate->aggfnoid)); ObjectIdGetDatum(originalAggregate->aggfnoid));
if (!HeapTupleIsValid(aggTuple)) if (!HeapTupleIsValid(aggTuple))
{ {
elog(WARNING, "!3434");
elog(WARNING, "citus cache lookup failed for aggregate %u", elog(WARNING, "citus cache lookup failed for aggregate %u",
originalAggregate->aggfnoid); originalAggregate->aggfnoid);
combine = InvalidOid; combine = InvalidOid;