diff --git a/src/backend/cdb/cdbcopy.c b/src/backend/cdb/cdbcopy.c index cd9213f3338ae93ee4d25145ec544416c10fc7bc..3eef484ab8b1acae40d9cf68d39a2c24a1d5aa0c 100644 --- a/src/backend/cdb/cdbcopy.c +++ b/src/backend/cdb/cdbcopy.c @@ -97,13 +97,10 @@ makeCdbCopy(bool is_copy_in) /* fresh start */ c->total_segs = 0; - c->mirror_map = NULL; c->copy_in = is_copy_in; - c->skip_ext_partition = false; c->outseglist = NIL; c->partitions = NULL; c->ao_segnos = NIL; - c->hasReplicatedTable = false; c->dispatcherState = NULL; initStringInfo(&(c->copy_out_buf)); @@ -142,8 +139,6 @@ cdbCopyStart(CdbCopy *c, CopyStmt *stmt, struct GpPolicy *policy) /* add in AO segno map for dispatch */ stmt->ao_segnos = c->ao_segnos; - stmt->skip_ext_partition = c->skip_ext_partition; - if (policy) { stmt->policy = GpPolicyCopy(policy); diff --git a/src/backend/commands/copy.c b/src/backend/commands/copy.c index 837897f95635aa3469ee710f6eaea7183346e717..f992b1a3c5da49c366a044eb15ca1b2a653b0a58 100644 --- a/src/backend/commands/copy.c +++ b/src/backend/commands/copy.c @@ -2640,8 +2640,6 @@ CopyToDispatch(CopyState cstate) cdbCopy = makeCdbCopy(false); cdbCopy->partitions = RelationBuildPartitionDesc(cstate->rel, false); - cdbCopy->skip_ext_partition = cstate->skip_ext_partition; - cdbCopy->hasReplicatedTable = GpPolicyIsReplicated(cstate->rel->rd_cdbpolicy); /* XXX: lock all partitions */ diff --git a/src/include/cdb/cdbcopy.h b/src/include/cdb/cdbcopy.h index 5d485aa80f90f391b8ee776f87ce01668764ffe1..f830992fec968e6b280f8e492c7b8db32f862410 100644 --- a/src/include/cdb/cdbcopy.h +++ b/src/include/cdb/cdbcopy.h @@ -28,9 +28,7 @@ struct CdbDispatcherState; typedef struct CdbCopy { int total_segs; /* total number of segments in cdb */ - int *mirror_map; /* indicates how many db's each segment has */ bool copy_in; /* direction: true for COPY FROM false for COPY TO */ - bool skip_ext_partition;/* skip external partition */ StringInfoData copy_out_buf;/* holds a chunk of data from the database */ @@ -40,7 +38,6 @@ typedef struct CdbCopy PartitionNode *partitions; List *ao_segnos; HTAB *aotupcounts; /* hash of ao relation id to processed tuple count */ - bool hasReplicatedTable; struct CdbDispatcherState *dispatcherState; } CdbCopy;