diff --git a/core/src/services/webhdfs/backend.rs b/core/src/services/webhdfs/backend.rs index 4f90b9d2cee0..86080ce52aaf 100644 --- a/core/src/services/webhdfs/backend.rs +++ b/core/src/services/webhdfs/backend.rs @@ -130,8 +130,8 @@ impl Builder for WebhdfsBuilder { map.get("endpoint").map(|v| builder.endpoint(v)); map.get("delegation").map(|v| builder.delegation(v)); map.get("disable_list_batch") - .map(|v| v == "true") - .map(|_v| builder.disable_list_batch()); + .filter(|v| v == &"true") + .map(|_| builder.disable_list_batch()); builder }