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

pull/6753/head
Gokhan Gulbiz 2023-03-16 10:40:02 +03:00
parent 57eaeb2ecb
commit 05f90b30d3
No known key found for this signature in database
GPG Key ID: 608EF06B6BD1B45B
1 changed files with 2 additions and 1 deletions

View File

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