Fix unset compression format panic

Sets the default compression format to None.
ArroyoSystems · Dec 14, 2023 · e319104 · e319104
1 parent 2e513f0
commit e319104
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/arroyo-worker/src/connectors/filesystem/source/mod.rs b/arroyo-worker/src/connectors/filesystem/source/mod.rs
@@ -97,7 +97,9 @@ impl<K: Data, T: SchemaData> FileSystemSourceFunc<K, T> {
         match &self.table {
             TableType::Source {
                 compression_format, ..
-            } => compression_format.clone().unwrap(),
+            } => compression_format
+                .clone()
+                .unwrap_or(CompressionFormat::None),
             TableType::Sink { .. } => unreachable!(),
         }
     }