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

Merge pull request #6069 from citusdata/assertion-fix 

fix assertion bugs related to list length
improve_locking_try_3
aykut-bozkurt 2022-07-20 12:00:11 +03:00 committed by GitHub
parent 6a32061c08 108ca875ad
commit c085ac026a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/commands/table.c
View File

@ -652,7 +652,7 @@ PostprocessAlterTableSchemaStmt(Node *node, const char *queryString)
List *tableAddresses = GetObjectAddressListFromParseTree((Node *) stmt, true); List *tableAddresses = GetObjectAddressListFromParseTree((Node *) stmt, true);
/* the code-path only supports a single object */ /* the code-path only supports a single object */
Assert(list_length(tableAddress) == 1); Assert(list_length(tableAddresses) == 1);
/* We have already asserted that we have exactly 1 address in the addresses. */ /* We have already asserted that we have exactly 1 address in the addresses. */
ObjectAddress *tableAddress = linitial(tableAddresses); ObjectAddress *tableAddress = linitial(tableAddresses);

2
src/backend/distributed/commands/type.c
View File

@ -120,7 +120,7 @@ PreprocessRenameTypeAttributeStmt(Node *node, const char *queryString,
List *typeAddresses = GetObjectAddressListFromParseTree((Node *) stmt, false); List *typeAddresses = GetObjectAddressListFromParseTree((Node *) stmt, false);
/* the code-path only supports a single object */ /* the code-path only supports a single object */
Assert(list_length(objectAddresses) == 1); Assert(list_length(typeAddresses) == 1);
if (!ShouldPropagateAnyObject(typeAddresses)) if (!ShouldPropagateAnyObject(typeAddresses))
{ {

2
src/backend/distributed/worker/worker_create_or_replace.c
View File

@ -182,7 +182,7 @@ WorkerCreateOrReplaceObject(List *sqlStatements)
*/ */
Node *parseTree = ParseTreeNode(linitial(sqlStatements)); Node *parseTree = ParseTreeNode(linitial(sqlStatements));
List *addresses = GetObjectAddressListFromParseTree(parseTree, true); List *addresses = GetObjectAddressListFromParseTree(parseTree, true);
Assert(list_length(viewAddresses) == 1); Assert(list_length(addresses) == 1);
/* We have already asserted that we have exactly 1 address in the addresses. */ /* We have already asserted that we have exactly 1 address in the addresses. */
ObjectAddress *address = linitial(addresses); ObjectAddress *address = linitial(addresses);