diff --git a/ballista/rust/core/src/serde/logical_plan/from_proto.rs b/ballista/rust/core/src/serde/logical_plan/from_proto.rs
index 389c1bdb722e6..10cc5e156889a 100644
--- a/ballista/rust/core/src/serde/logical_plan/from_proto.rs
+++ b/ballista/rust/core/src/serde/logical_plan/from_proto.rs
@@ -1102,6 +1102,7 @@ impl TryInto<Expr> for &protobuf::LogicalExprNode {
                 }
             }
             ExprType::ScalarUdfProtoExpr(expr) => {
+                println!("from_proto to logical plan-----------------");
                 if let Some(udf_plugin_manager) = get_udf_plugin_manager("") {
                     let fun = udf_plugin_manager
                         .scalar_udfs
@@ -1112,6 +1113,7 @@ impl TryInto<Expr> for &protobuf::LogicalExprNode {
                                 expr.fun_name.to_string()
                             ))
                         })?;
+                    println!("found udf-------------------");
                     let fun_arc = fun.clone();
                     let fun_args = &expr.args;
                     let args: Vec<Expr> = fun_args
diff --git a/ballista/rust/core/src/serde/physical_plan/from_proto.rs b/ballista/rust/core/src/serde/physical_plan/from_proto.rs
index 38c04ef29dd3b..1e3052ff1adb4 100644
--- a/ballista/rust/core/src/serde/physical_plan/from_proto.rs
+++ b/ballista/rust/core/src/serde/physical_plan/from_proto.rs
@@ -581,6 +581,7 @@ impl TryFrom<&protobuf::PhysicalExprNode> for Arc<dyn PhysicalExpr> {
             }
             // argo engine add.
             ExprType::ScalarUdfProtoExpr(e) => {
+                println!("from proto to physical plan----------------");
                 if let Some(udf_plugin_manager) = get_udf_plugin_manager("") {
                     let fun = udf_plugin_manager
                         .scalar_udfs
@@ -591,8 +592,8 @@ impl TryFrom<&protobuf::PhysicalExprNode> for Arc<dyn PhysicalExpr> {
                                 &e.fun_name.to_owned()
                             ))
                         })?;
-
                     let scalar_udf = &*fun.clone();
+                    println!("found udf-------------------");
                     let args = e
                         .expr
                         .iter()