diff --git a/nexus/server/src/main.rs b/nexus/server/src/main.rs index 4a1eebe7e1..ef9c97737d 100644 --- a/nexus/server/src/main.rs +++ b/nexus/server/src/main.rs @@ -416,7 +416,6 @@ impl NexusBackend { let table_mappings_count = flow_job.table_mappings.len(); if table_mappings_count > 1 { let mut sources = HashSet::with_capacity(table_mappings_count); - let mut destinations = HashSet::with_capacity(table_mappings_count); for tm in flow_job.table_mappings.iter() { if !sources.insert(tm.source_table_identifier.as_str()) { return Err(PgWireError::ApiError( @@ -427,15 +426,6 @@ impl NexusBackend { .into(), )); } - if !destinations.insert(tm.destination_table_identifier.as_str()) { - return Err(PgWireError::ApiError( - format!( - "Duplicate destination table identifier {}", - tm.destination_table_identifier - ) - .into(), - )); - } } }