update

Author: luoluoyuyu

src/runtime/streaming/factory/connector/mod.rs

@@ -14,4 +14,4 @@ mod dispatchers;
 pub mod kafka;
 
 pub use dispatchers::{ConnectorSinkDispatcher, ConnectorSourceDispatcher};
-pub use kafka::{KafkaConnectorDispatcher};
+pub use kafka::KafkaConnectorDispatcher;

src/runtime/streaming/factory/mod.rs

@@ -21,9 +21,7 @@ use tracing::info;
 use crate::sql::common::constants::factory_operator_name;
 
 #[allow(unused_imports)]
-pub use connector::{
-    ConnectorSinkDispatcher, ConnectorSourceDispatcher, KafkaConnectorDispatcher,
-};
+pub use connector::{ConnectorSinkDispatcher, ConnectorSourceDispatcher, KafkaConnectorDispatcher};
 pub use global::Registry;
 pub use operator_factory::OperatorFactory;
 

src/sql/extensions/key_calculation.rs

@@ -237,10 +237,7 @@ impl StreamingOperatorBlueprint for KeyExtractionNode {
             format!("key_{node_index}"),
             engine_operator_name,
             protobuf_payload,
-            format!(
-                "Key<{}>",
-                self.operator_label.as_deref().unwrap_or("_")
-            ),
+            format!("Key<{}>", self.operator_label.as_deref().unwrap_or("_")),
             1,
         );