Skip to content

Commit 3b42d52

Browse files
authored
Add print (#5)
* 修复插件加载的bug
1 parent edffe28 commit 3b42d52

File tree

2 files changed

+1
-7
lines changed

2 files changed

+1
-7
lines changed

datafusion/src/plugin/plugin_manager.rs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,6 @@ impl GlobalPluginManager {
6262
}
6363
// find library file from udaf_plugin_path
6464
info!("load plugin from dir:{}", plugin_path);
65-
println!("load plugin from dir:{}", plugin_path);
6665

6766
let plugin_files = self.get_all_plugin_files(plugin_path)?;
6867

@@ -83,7 +82,7 @@ impl GlobalPluginManager {
8382
"not found plugin_declaration in the library: {}",
8483
plugin_file.path().to_str().unwrap()
8584
);
86-
return Ok(());
85+
continue;
8786
}
8887

8988
let dec = dec.unwrap().read();
@@ -140,10 +139,6 @@ impl GlobalPluginManager {
140139
"load plugin from library file:{}",
141140
item.path().to_str().unwrap()
142141
);
143-
println!(
144-
"load plugin from library file:{}",
145-
item.path().to_str().unwrap()
146-
);
147142
return Some(item);
148143
}
149144
}

datafusion/src/plugin/udf.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,6 @@ impl PluginRegistrar for UDFPluginManager {
6363
format!("not found fn registrar_udf_plugin in the library: {}", e),
6464
))
6565
})?;
66-
println!("1111111111111111111111");
6766
let udf_plugin: Box<dyn UDFPlugin> = register_fun();
6867
udf_plugin
6968
.udf_names()

0 commit comments

Comments
 (0)