mirror of https://github.com/citusdata/citus.git
Create shell always for dist and reference table
parent
d18525a906
commit
cfe3f97faf
|
@ -532,19 +532,20 @@ CreateDistributedTable(Oid relationId, Var *distributionColumn, char distributio
|
||||||
CreateReferenceTableShard(relationId);
|
CreateReferenceTableShard(relationId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
CreateShellTableOnWorkers(relationId);
|
||||||
if (ShouldSyncTableMetadata(relationId))
|
if (ShouldSyncTableMetadata(relationId))
|
||||||
{
|
{
|
||||||
CreateShellTableOnWorkers(relationId);
|
MarkObjectDistributed(&tableAddress);
|
||||||
|
|
||||||
/* TODO: Consider partitioned tables */
|
|
||||||
// TODO: Should we really check? or don't allow
|
|
||||||
if (EnableDependencyCreation)
|
|
||||||
{
|
|
||||||
MarkObjectDistributed(&tableAddress);
|
|
||||||
}
|
|
||||||
|
|
||||||
CreateTableMetadataOnWorkers(relationId);
|
CreateTableMetadataOnWorkers(relationId);
|
||||||
}
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
// Mark the table as distributed only locally
|
||||||
|
bool prevDependencyCreationValue = EnableDependencyCreation;
|
||||||
|
SetLocalEnableDependencyCreation(false);
|
||||||
|
MarkObjectDistributed(&tableAddress);
|
||||||
|
SetLocalEnableDependencyCreation(prevDependencyCreationValue);
|
||||||
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* We've a custom way of foreign key graph invalidation,
|
* We've a custom way of foreign key graph invalidation,
|
||||||
|
|
Loading…
Reference in New Issue