fix distribution

risingwavelabs · Oct 9, 2024 · 5563087 · 5563087
1 parent 818f8a3
commit 5563087
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/frontend/src/optimizer/plan_node/batch_postgres_query.rs b/src/frontend/src/optimizer/plan_node/batch_postgres_query.rs
@@ -45,7 +45,7 @@ impl BatchPostgresQuery {
     pub fn clone_with_dist(&self) -> Self {
         let base = self
             .base
-            .clone_with_new_distribution(Distribution::SomeShard);
+            .clone_with_new_distribution(Distribution::Single);
         Self {
             base,
             core: self.core.clone(),