mirror of https://github.com/citusdata/citus.git
Use Row Exclusive Lock on distributed table
parent
77356592fb
commit
6404431f16
|
@ -333,7 +333,7 @@ CitusCopyFrom(CopyStmt *copyStatement, char *completionTag)
|
||||||
compareFunction = ShardIntervalCompareFunction(partitionColumn, partitionMethod);
|
compareFunction = ShardIntervalCompareFunction(partitionColumn, partitionMethod);
|
||||||
|
|
||||||
/* allocate column values and nulls arrays */
|
/* allocate column values and nulls arrays */
|
||||||
rel = heap_open(tableId, AccessShareLock);
|
rel = heap_open(tableId, RowExclusiveLock);
|
||||||
tupleDescriptor = RelationGetDescr(rel);
|
tupleDescriptor = RelationGetDescr(rel);
|
||||||
columnCount = tupleDescriptor->natts;
|
columnCount = tupleDescriptor->natts;
|
||||||
columnValues = palloc0(columnCount * sizeof(Datum));
|
columnValues = palloc0(columnCount * sizeof(Datum));
|
||||||
|
|
Loading…
Reference in New Issue