We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e86c7dc commit 01d5e71Copy full SHA for 01d5e71
datafusion/functions-nested/src/set_ops.rs
@@ -290,10 +290,14 @@ impl ScalarUDFImpl for ArrayDistinct {
290
291
fn return_type(&self, arg_types: &[DataType]) -> Result<DataType> {
292
match &arg_types[0] {
293
- List(field) => Ok(DataType::new_list(field.data_type().clone(), true)),
294
- LargeList(field) => {
295
- Ok(DataType::new_large_list(field.data_type().clone(), true))
296
- }
+ List(field) => Ok(DataType::new_list(
+ field.data_type().clone(),
+ field.is_nullable(),
+ )),
297
+ LargeList(field) => Ok(DataType::new_large_list(
298
299
300
301
arg_type => plan_err!("{} does not support type {arg_type}", self.name()),
302
}
303
0 commit comments