fix

risingwavelabs · Nov 7, 2024 · d9d9ac8 · d9d9ac8
1 parent e2f1722
commit d9d9ac8
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 7 deletions.
diff --git a/src/frontend/src/binder/expr/mod.rs b/src/frontend/src/binder/expr/mod.rs
@@ -91,15 +91,16 @@ impl Binder {
                     }
                 } else {
                     if let Some(ctx) = self.secure_compare_context.as_ref() {
-                        if ident.real_value() == ctx.secret_name  {
+                        if ident.real_value() == ctx.secret_name {
                             Ok(InputRef::new(0, DataType::Varchar).into())
                         } else if ident.real_value() == ctx.column_name {
                             Ok(InputRef::new(1, DataType::Bytea).into())
                         } else {
-                            Err(
-                                ErrorCode::ItemNotFound(format!("Unknown arg: {}", ident.real_value()))
-                                    .into(),
-                            )
+                            Err(ErrorCode::ItemNotFound(format!(
+                                "Unknown arg: {}",
+                                ident.real_value()
+                            ))
+                            .into())
                         }
                     } else {
                         self.bind_column(&[ident])

diff --git a/src/frontend/src/optimizer/mod.rs b/src/frontend/src/optimizer/mod.rs
@@ -57,7 +57,7 @@ use risingwave_common::types::DataType;
 use risingwave_common::util::column_index_mapping::ColIndexMapping;
 use risingwave_common::util::iter_util::ZipEqDebug;
 use risingwave_connector::sink::catalog::SinkFormatDesc;
-use risingwave_pb::catalog::{WatermarkDesc, PbWebhookSourceInfo};
+use risingwave_pb::catalog::{PbWebhookSourceInfo, WatermarkDesc};
 use risingwave_pb::stream_plan::StreamScanType;
 
 use self::heuristic_optimizer::ApplyOrder;

diff --git a/src/meta/model/src/lib.rs b/src/meta/model/src/lib.rs
@@ -369,7 +369,10 @@ derive_array_from_blob!(
     PbColumnCatalogArray
 );
 derive_from_blob!(StreamSourceInfo, risingwave_pb::catalog::PbStreamSourceInfo);
-derive_from_blob!(WebhookSourceInfo, risingwave_pb::catalog::PbWebhookSourceInfo);
+derive_from_blob!(
+    WebhookSourceInfo,
+    risingwave_pb::catalog::PbWebhookSourceInfo
+);
 derive_from_blob!(WatermarkDesc, risingwave_pb::catalog::PbWatermarkDesc);
 derive_array_from_blob!(
     WatermarkDescArray,