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

Always use GetNextCleanupRecordId

fix-flaky-citus_split_shard_by_split_points_deferred_drop-2
Jelte Fennema 2023-04-03 12:59:41 +02:00
parent b2f6cc877f
commit 6f8acfdde7
2 changed files with 4 additions and 7 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),

2
src/test/regress/expected/citus_split_shard_by_split_points_deferred_drop.out
View File

@ -67,7 +67,7 @@ SELECT pg_catalog.citus_split_shard_by_split_points(
SELECT * from pg_dist_cleanup;
record_id | operation_id | object_type | object_name | node_group_id | policy_type
---------------------------------------------------------------------
512 | 778 | 1 | citus_split_shard_by_split_points_deferred_schema.table_to_split_8981001 | 16 | 2
526 | 778 | 1 | citus_split_shard_by_split_points_deferred_schema.table_to_split_8981001 | 16 | 2
(1 row)
-- One of the physical shards should not be deleted, the other one should.