Add print for

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

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()

datafusion/src/execution/context.rs

@@ -197,6 +197,7 @@ impl ExecutionContext {
         };
 
         // register udf
+        println!("register udf to context---------------");
         if let Some(udf_plugin_manager) =
             get_udf_plugin_manager(config.plugin_dir.as_str())
         {
@@ -212,6 +213,7 @@ impl ExecutionContext {
                     context.register_udaf((**aggregate_udf).clone())
                 });
         }
+        println!("register udf to context--------success-------");
         context
     }
 

datafusion/src/plugin/udf.rs

@@ -136,6 +136,7 @@ macro_rules! declare_udf_plugin {
 
 /// get a Option of Immutable UDFPluginManager
 pub fn get_udf_plugin_manager(path: &str) -> Option<UDFPluginManager> {
+    println!("get_udf_plugin_manager:{}", path);
     let udf_plugin_manager_opt = {
         let gpm = global_plugin_manager(path).lock().unwrap();
         let plugin_registrar_opt = gpm.plugin_managers.get(&PluginEnum::UDF);