diff --git a/src/execution/operator/aggregate/physical_streaming_window.cpp b/src/execution/operator/aggregate/physical_streaming_window.cpp index 2eee389f178..aad0c0b3034 100644 --- a/src/execution/operator/aggregate/physical_streaming_window.cpp +++ b/src/execution/operator/aggregate/physical_streaming_window.cpp @@ -61,8 +61,10 @@ class StreamingWindowState : public OperatorState { for (auto &child : wexpr.children) { arg_types.push_back(child->return_type); } - arg_chunk.Initialize(allocator, arg_types); - arg_cursor.Initialize(allocator, arg_types); + if (!arg_types.empty()) { + arg_chunk.Initialize(allocator, arg_types); + arg_cursor.Initialize(allocator, arg_types); + } if (wexpr.filter_expr) { filter_sel.Initialize(); }