diff --git a/src/backend/distributed/worker/worker_data_fetch_protocol.c b/src/backend/distributed/worker/worker_data_fetch_protocol.c index 86e43749d..8b984ee3f 100644 --- a/src/backend/distributed/worker/worker_data_fetch_protocol.c +++ b/src/backend/distributed/worker/worker_data_fetch_protocol.c @@ -160,6 +160,12 @@ worker_modify_identity_columns(PG_FUNCTION_ARGS) Form_pg_attribute attributeForm = TupleDescAttr(tableTupleDesc, attributeIndex); + /* skip dropped columns */ + if (attributeForm->attisdropped) + { + continue; + } + if (attributeForm->attidentity) { Oid sequenceOid = getIdentitySequence(tableRelationId,