diff --git a/core/src/execution/datafusion/shuffle_writer.rs b/core/src/execution/datafusion/shuffle_writer.rs index f538a5fd2..f836e3a40 100644 --- a/core/src/execution/datafusion/shuffle_writer.rs +++ b/core/src/execution/datafusion/shuffle_writer.rs @@ -461,31 +461,31 @@ fn append_columns( } macro_rules! append_byte_dict { - ($kt:ident, $byte_type:ty, $array:ty) => {{ + ($kt:ident, $byte_type:ty, $array_type:ty) => {{ match $kt.as_ref() { DataType::Int8 => { - append_dict!(Int8Type, GenericByteDictionaryBuilder, $array) + append_dict!(Int8Type, GenericByteDictionaryBuilder, $array_type) } DataType::Int16 => { - append_dict!(Int16Type, GenericByteDictionaryBuilder, $array) + append_dict!(Int16Type, GenericByteDictionaryBuilder, $array_type) } DataType::Int32 => { - append_dict!(Int32Type, GenericByteDictionaryBuilder, $array) + append_dict!(Int32Type, GenericByteDictionaryBuilder, $array_type) } DataType::Int64 => { - append_dict!(Int64Type, GenericByteDictionaryBuilder, $array) + append_dict!(Int64Type, GenericByteDictionaryBuilder, $array_type) } DataType::UInt8 => { - append_dict!(UInt8Type, GenericByteDictionaryBuilder, $array) + append_dict!(UInt8Type, GenericByteDictionaryBuilder, $array_type) } DataType::UInt16 => { - append_dict!(UInt16Type, GenericByteDictionaryBuilder, $array) + append_dict!(UInt16Type, GenericByteDictionaryBuilder, $array_type) } DataType::UInt32 => { - append_dict!(UInt32Type, GenericByteDictionaryBuilder, $array) + append_dict!(UInt32Type, GenericByteDictionaryBuilder, $array_type) } DataType::UInt64 => { - append_dict!(UInt64Type, GenericByteDictionaryBuilder, $array) + append_dict!(UInt64Type, GenericByteDictionaryBuilder, $array_type) } _ => unreachable!("Unknown key type for dictionary"), }