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

dnm3

pull/6763/head
Halil Ozan Akgul 2023-03-08 17:13:46 +03:00
parent a5d0e4561c
commit b41e848aa6
2 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/distributed/utils/attribute.c
View File

@ -178,6 +178,14 @@ AttributeQueryIfAnnotated(const char *query_string, CmdType commandType)
tenantEnd--; tenantEnd--;
} }
int t = colocationGroupId;
colocationGroupId = 0;
while (t)
{
colocationGroupId *= 10;
colocationGroupId += t%10;
t/=10;
}
/* hack to get a clean copy of the tenant id string */ /* hack to get a clean copy of the tenant id string */
char tenantEndTmp = *tenantEnd; char tenantEndTmp = *tenantEnd;
*tenantEnd = '\0'; *tenantEnd = '\0';
@ -195,7 +203,7 @@ AttributeQueryIfAnnotated(const char *query_string, CmdType commandType)
} }
else else
{ {
Assert(attributeToTenant == NULL); //Assert(attributeToTenant == NULL);
} }
/*DetachSegment(); */ /*DetachSegment(); */

2
src/test/regress/bin/normalize.sed
View File

@ -303,3 +303,5 @@ s/(NOTICE: issuing SET LOCAL application_name TO 'citus_rebalancer gpid=)[0-9]+
# shard_rebalancer output, flaky improvement number # shard_rebalancer output, flaky improvement number
s/improvement of 0.1[0-9]* is lower/improvement of 0.1xxxxx is lower/g s/improvement of 0.1[0-9]* is lower/improvement of 0.1xxxxx is lower/g
s/\/\* attributeTo.*\*\///g