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

Set INVALID_COLOCATION_ID if colocationId doesn't exist in the annotation.

pull/6763/head^2
Gokhan Gulbiz 2023-03-16 10:40:02 +03:00
parent c60de03d6a
commit a355825bfe
No known key found for this signature in database
GPG Key ID: 608EF06B6BD1B45B
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -18,6 +18,7 @@
#include "distributed/jsonbutils.h" #include "distributed/jsonbutils.h"
#include "distributed/colocation_utils.h" #include "distributed/colocation_utils.h"
#include "distributed/tuplestore.h" #include "distributed/tuplestore.h"
#include "distributed/colocation_utils.h"
#include "executor/execdesc.h" #include "executor/execdesc.h"
#include "storage/ipc.h" #include "storage/ipc.h"
#include "storage/lwlock.h" #include "storage/lwlock.h"
@ -219,7 +220,7 @@ AttributeQueryIfAnnotated(const char *query_string, CmdType commandType)
strcpy_s(attributeToTenant, sizeof(attributeToTenant), tenantId); strcpy_s(attributeToTenant, sizeof(attributeToTenant), tenantId);
} }
colocationGroupId = ExtractFieldInt32(jsonbDatum, "cId", INVALID_COLOCATION_ID); colocationGroupId = ExtractFieldInt32(jsonbDatum, "cId", INVALID_COLOCATION_ID);
if (MultiTenantMonitoringLogLevel != CITUS_LOG_LEVEL_OFF) if (MultiTenantMonitoringLogLevel != CITUS_LOG_LEVEL_OFF)
{ {