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

test

test-flaky-tests
ahmet gedemenli 2023-04-03 16:21:29 +03:00
parent 697bb55fc5
commit 2032afcb70
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/backend/distributed/operations/shard_cleaner.c
View File

@ -514,19 +514,16 @@ InsertCleanupRecordInSubtransaction(CleanupObject objectType,
*/
Assert(CurrentOperationId != INVALID_OPERATION_ID);
StringInfo sequenceName = makeStringInfo();
appendStringInfo(sequenceName, "%s.%s",
PG_CATALOG,
CLEANUPRECORDID_SEQUENCE_NAME);
uint64 recordId = GetNextCleanupRecordId();
StringInfo command = makeStringInfo();
appendStringInfo(command,
"INSERT INTO %s.%s "
" (record_id, operation_id, object_type, object_name, node_group_id, policy_type) "
" VALUES ( nextval('%s'), " UINT64_FORMAT ", %d, %s, %d, %d)",
" VALUES ( %lu, " UINT64_FORMAT ", %d, %s, %d, %d)",
PG_CATALOG,
PG_DIST_CLEANUP,
sequenceName->data,
recordId,
CurrentOperationId,
objectType,
quote_literal_cstr(objectName),