File tree Expand file tree Collapse file tree 2 files changed +6
-14
lines changed Expand file tree Collapse file tree 2 files changed +6
-14
lines changed Original file line number Diff line number Diff line change @@ -141,7 +141,7 @@ impl ExprSchemable for Expr {
141
141
// verify that function is invoked with correct number and type of arguments as defined in `TypeSignature`
142
142
data_types_with_scalar_udf ( & arg_data_types, func) . map_err ( |err| {
143
143
plan_datafusion_err ! (
144
- "{} and {}" ,
144
+ "{} {}" ,
145
145
err,
146
146
utils:: generate_signature_error_msg(
147
147
func. name( ) ,
@@ -164,7 +164,7 @@ impl ExprSchemable for Expr {
164
164
WindowFunctionDefinition :: AggregateUDF ( udf) => {
165
165
let new_types = data_types_with_aggregate_udf ( & data_types, udf) . map_err ( |err| {
166
166
plan_datafusion_err ! (
167
- "{} and {}" ,
167
+ "{} {}" ,
168
168
err,
169
169
utils:: generate_signature_error_msg(
170
170
fun. name( ) ,
@@ -192,7 +192,7 @@ impl ExprSchemable for Expr {
192
192
AggregateFunctionDefinition :: UDF ( fun) => {
193
193
let new_types = data_types_with_aggregate_udf ( & data_types, fun) . map_err ( |err| {
194
194
plan_datafusion_err ! (
195
- "{} and {}" ,
195
+ "{} {}" ,
196
196
err,
197
197
utils:: generate_signature_error_msg(
198
198
fun. name( ) ,
Original file line number Diff line number Diff line change @@ -49,10 +49,7 @@ pub fn data_types_with_scalar_udf(
49
49
if signature. type_signature . supports_zero_argument ( ) {
50
50
return Ok ( vec ! [ ] ) ;
51
51
} else {
52
- return plan_err ! (
53
- "[data_types_with_scalar_udf] signature {:?} does not support zero arguments." ,
54
- & signature. type_signature
55
- ) ;
52
+ return plan_err ! ( "{} does not support zero arguments." , func. name( ) ) ;
56
53
}
57
54
}
58
55
@@ -79,11 +76,7 @@ pub fn data_types_with_aggregate_udf(
79
76
if signature. type_signature . supports_zero_argument ( ) {
80
77
return Ok ( vec ! [ ] ) ;
81
78
} else {
82
- return plan_err ! (
83
- "[data_types_with_aggregate_udf] Coercion from {:?} to the signature {:?} failed." ,
84
- current_types,
85
- & signature. type_signature
86
- ) ;
79
+ return plan_err ! ( "{} does not support zero arguments." , func. name( ) ) ;
87
80
}
88
81
}
89
82
@@ -118,8 +111,7 @@ pub fn data_types(
118
111
return Ok ( vec ! [ ] ) ;
119
112
} else {
120
113
return plan_err ! (
121
- "[data_types] Coercion from {:?} to the signature {:?} failed." ,
122
- current_types,
114
+ "signature {:?} does not support zero arguments." ,
123
115
& signature. type_signature
124
116
) ;
125
117
}
You can’t perform that action at this time.
0 commit comments