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

Bug fix

pull/6029/head
Nitish Upreti 2022-06-23 22:14:44 -07:00
parent 2f3f212746
commit f3a391b80f
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/operations/isolate_shards.c
View File

@ -560,7 +560,7 @@ SplitOffCommandList(ShardInterval *sourceShard, ShardInterval *splitOffShard)
* commands in parallel. Finally, it sends commit messages to all connections * commands in parallel. Finally, it sends commit messages to all connections
* and close them. * and close them.
*/ */
void static void
ExecuteCommandListOnPlacements(List *commandList, List *placementList) ExecuteCommandListOnPlacements(List *commandList, List *placementList)
{ {
List *workerConnectionList = NIL; List *workerConnectionList = NIL;

6
src/backend/distributed/operations/shard_split.c
View File

@ -570,10 +570,10 @@ CreateSplitCopyCommand(ShardInterval *sourceShardSplitInterval,
StringInfo splitCopyInfoRow = makeStringInfo(); StringInfo splitCopyInfoRow = makeStringInfo();
appendStringInfo(splitCopyInfoRow, appendStringInfo(splitCopyInfoRow,
"ROW(%lu, %lu, %lu, %u)::citus.split_copy_info", "ROW(%lu, %d, %d, %u)::citus.split_copy_info",
splitChildShardInterval->shardId, splitChildShardInterval->shardId,
splitChildShardInterval->minValue, DatumGetInt32(splitChildShardInterval->minValue),
splitChildShardInterval->maxValue, DatumGetInt32(splitChildShardInterval->maxValue),
destinationWorkerNode->nodeId); destinationWorkerNode->nodeId);
appendStringInfo(splitCopyInfoArray, "%s", splitCopyInfoRow->data); appendStringInfo(splitCopyInfoArray, "%s", splitCopyInfoRow->data);

4
src/backend/distributed/operations/worker_split_copy_udf.c
View File

@ -98,7 +98,7 @@ ParseSplitCopyInfoDatum(Datum splitCopyInfoDatum, SplitCopyInfo **splitCopyInfo)
"destination_shard_min_value for split_copy_info cannot be null."))); "destination_shard_min_value for split_copy_info cannot be null.")));
} }
char *destinationMinHash = text_to_cstring(DatumGetTextP(minValueDatum)); char *destinationMinHash = text_to_cstring(DatumGetTextP(minValueDatum));
copyInfo->destinationShardMinHashValue = pg_strtoint64(destinationMinHash); copyInfo->destinationShardMinHashValue = pg_strtoint32(destinationMinHash);
Datum maxValueDatum = GetAttributeByName(dataTuple, "destination_shard_max_value", Datum maxValueDatum = GetAttributeByName(dataTuple, "destination_shard_max_value",
&isnull); &isnull);
@ -108,7 +108,7 @@ ParseSplitCopyInfoDatum(Datum splitCopyInfoDatum, SplitCopyInfo **splitCopyInfo)
"destination_shard_max_value for split_copy_info cannot be null."))); "destination_shard_max_value for split_copy_info cannot be null.")));
} }
char *destinationMaxHash = text_to_cstring(DatumGetTextP(maxValueDatum)); char *destinationMaxHash = text_to_cstring(DatumGetTextP(maxValueDatum));
copyInfo->destinationShardMaxHashValue = pg_strtoint64(destinationMaxHash); copyInfo->destinationShardMaxHashValue = pg_strtoint32(destinationMaxHash);
Datum nodeIdDatum = GetAttributeByName(dataTuple, "destination_shard_node_id", Datum nodeIdDatum = GetAttributeByName(dataTuple, "destination_shard_node_id",
&isnull); &isnull);