fix

risingwavelabs · Nov 18, 2024 · a446707 · a446707
1 parent cc75ea7
commit a446707
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/frontend/src/handler/create_sink.rs b/src/frontend/src/handler/create_sink.rs
@@ -77,6 +77,7 @@ use crate::{Explain, Planner, TableCatalog, WithOptions, WithOptionsSecResolved}
 
 static ALLOWED_CONNECTION_CONNECTOR: LazyLock<HashSet<PbConnectionType>> = LazyLock::new(|| {
     hashset! {
+        PbConnectionType::Unspecified,
         PbConnectionType::Kafka,
         PbConnectionType::Iceberg,
     }

diff --git a/src/frontend/src/handler/create_source.rs b/src/frontend/src/handler/create_source.rs
@@ -1076,6 +1076,7 @@ pub(super) fn bind_source_watermark(
 
 static ALLOWED_CONNECTION_CONNECTOR: LazyLock<HashSet<PbConnectionType>> = LazyLock::new(|| {
     hashset! {
+        PbConnectionType::Unspecified,
         PbConnectionType::Kafka,
         PbConnectionType::Iceberg,
     }