From 7e28c67c305460c285b96176f2a2f69a7b619fd0 Mon Sep 17 00:00:00 2001 From: Jay Zhan Date: Tue, 25 Feb 2025 20:10:36 +0800 Subject: [PATCH] rm length check --- datafusion/functions/src/math/gcd.rs | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) diff --git a/datafusion/functions/src/math/gcd.rs b/datafusion/functions/src/math/gcd.rs index 78deb2a7965b..7fe253b4afbc 100644 --- a/datafusion/functions/src/math/gcd.rs +++ b/datafusion/functions/src/math/gcd.rs @@ -23,9 +23,7 @@ use std::any::Any; use std::mem::swap; use std::sync::Arc; -use datafusion_common::{ - exec_err, internal_datafusion_err, internal_err, Result, ScalarValue, -}; +use datafusion_common::{exec_err, internal_datafusion_err, Result, ScalarValue}; use datafusion_expr::{ ColumnarValue, Documentation, ScalarFunctionArgs, ScalarUDFImpl, Signature, Volatility, @@ -114,13 +112,6 @@ impl ScalarUDFImpl for GcdFunc { fn compute_gcd_for_arrays(a: &ArrayRef, b: &ArrayRef) -> Result { let a = a.as_primitive::(); let b = b.as_primitive::(); - if a.len() != b.len() { - return internal_err!( - "Length of arguments for function gcd do not match: {} vs {}", - a.len(), - b.len() - ); - } try_binary(a, b, compute_gcd) .map(|arr: PrimitiveArray| { ColumnarValue::Array(Arc::new(arr) as ArrayRef)