diff --git a/src/pipeline/src/etl.rs b/src/pipeline/src/etl.rs
index b24768145b..8f87f8305b 100644
--- a/src/pipeline/src/etl.rs
+++ b/src/pipeline/src/etl.rs
@@ -218,7 +218,7 @@ impl From<&Rule> for DispatchedTo {
 impl DispatchedTo {
     /// Generate destination table name from input
     pub fn dispatched_to_table_name(&self, original: &str) -> String {
-        format!("{}_{}", &original, self.table_suffix)
+        [original, &self.table_suffix].concat()
     }
 }
 
diff --git a/tests-integration/tests/http.rs b/tests-integration/tests/http.rs
index 4decd7f5f3..4f031a4851 100644
--- a/tests-integration/tests/http.rs
+++ b/tests-integration/tests/http.rs
@@ -2517,12 +2517,12 @@ dispatcher:
   field: type
   rules:
     - value: http
-      table_suffix: http
+      table_suffix: _http
       pipeline: http
     - value: db
-      table_suffix: db
+      table_suffix: _db
     - value: not_found
-      table_suffix: not_found
+      table_suffix: _not_found
       pipeline: not_found
 
 transform: