fix operator name

ArroyoSystems · Oct 20, 2023 · d1bdd16 · d1bdd16
1 parent 9d7aea8
commit d1bdd16
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/arroyo-connectors/src/filesystem.rs b/arroyo-connectors/src/filesystem.rs
@@ -82,8 +82,8 @@ impl Connector for FileSystemConnector {
     ) -> anyhow::Result<crate::Connection> {
         let (description, operator, connection_type) = match table.type_ {
             TableType::Source { .. } => (
-                "FileSystem<Plain>".to_string(),
-                "connectors::filesystem",
+                "FileSystem<S3>".to_string(),
+                "connectors::filesystem::source::FileSystemSourceFunc",
                 ConnectionType::Source,
             ),
             TableType::Sink {