diff --git a/src/Interpreters/HashJoin.cpp b/src/Interpreters/HashJoin.cpp index d5392d718112..799a5d01f174 100644 --- a/src/Interpreters/HashJoin.cpp +++ b/src/Interpreters/HashJoin.cpp @@ -1584,6 +1584,14 @@ ColumnPtr buildAdditionalFilter( sample_right_block.dumpNames(), added_columns.left_block.dumpNames()); } + // Debug + for (const auto & col : executed_block.getColumnsWithTypeAndName()) + { + if (!col.column || !col.type) + { + throw Exception(ErrorCodes::LOGICAL_ERROR, "Null column in input block. {}", executed_block.dumpStructure()); + } + } added_columns.additional_filter_expression->execute(executed_block); return executed_block.getByPosition(0).column; }