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

m

write_intermediate_results
Hadi Moshayedi 2019-12-05 10:53:52 -08:00
parent b73b0242bf
commit 35c433ff94
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/executor/intermediate_results.c
View File

@ -16,6 +16,7 @@
#include "miscadmin.h" #include "miscadmin.h"
#include "pgstat.h" #include "pgstat.h"
#include "access/htup_details.h"
#include "catalog/pg_enum.h" #include "catalog/pg_enum.h"
#include "commands/copy.h" #include "commands/copy.h"
#include "distributed/commands/multi_copy.h" #include "distributed/commands/multi_copy.h"
@ -124,7 +125,6 @@ write_intermediate_result_sfunc(PG_FUNCTION_ARGS)
if (state == NULL) if (state == NULL)
{ {
MemoryContext agg_context; MemoryContext agg_context;
MemoryContext old_context;
text *resultId = PG_GETARG_TEXT_P(1); text *resultId = PG_GETARG_TEXT_P(1);
char *resultIdString = text_to_cstring(resultId); char *resultIdString = text_to_cstring(resultId);
@ -134,7 +134,7 @@ write_intermediate_result_sfunc(PG_FUNCTION_ARGS)
elog(ERROR, "aggregate function called in non-aggregate context"); elog(ERROR, "aggregate function called in non-aggregate context");
} }
old_context = MemoryContextSwitchTo(agg_context); MemoryContext old_context = MemoryContextSwitchTo(agg_context);
state = palloc0(sizeof(WriteIntermediateResultsState)); state = palloc0(sizeof(WriteIntermediateResultsState));
Oid tupType = HeapTupleHeaderGetTypeId(rec); Oid tupType = HeapTupleHeaderGetTypeId(rec);