From d9d9ac88e2445c51413261904c15700d84e3384e Mon Sep 17 00:00:00 2001
From: Kexiang Wang <kx.wang@hotmail.com>
Date: Wed, 6 Nov 2024 19:49:09 -0500
Subject: [PATCH] fix

---
 src/frontend/src/binder/expr/mod.rs | 11 ++++++-----
 src/frontend/src/optimizer/mod.rs   |  2 +-
 src/meta/model/src/lib.rs           |  5 ++++-
 3 files changed, 11 insertions(+), 7 deletions(-)

diff --git a/src/frontend/src/binder/expr/mod.rs b/src/frontend/src/binder/expr/mod.rs
index 2a0641c8f1fe6..455f10ea3c0ca 100644
--- 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
index 3f09d7c58dac2..40d6fbca1d83d 100644
--- 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
index 5ef5b50d190ba..9995d8482b8fb 100644
--- 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,