From a18c6f7f8e20bc3c301cb077525e5503a392bed3 Mon Sep 17 00:00:00 2001 From: Ilya Golshtein Date: Mon, 2 Aug 2021 03:18:44 +0300 Subject: [PATCH] merge error fixed --- src/Interpreters/HashJoin.cpp | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/Interpreters/HashJoin.cpp b/src/Interpreters/HashJoin.cpp index 23c441eddce..ba6df55949d 100644 --- a/src/Interpreters/HashJoin.cpp +++ b/src/Interpreters/HashJoin.cpp @@ -205,6 +205,7 @@ HashJoin::HashJoin(std::shared_ptr table_join_, const Block & right_s , right_sample_block(right_sample_block_) , log(&Poco::Logger::get("HashJoin")) { + LOG_DEBUG(log, "Right sample block: {}", right_sample_block.dumpStructure()); bool multiple_disjuncts = key_names_right.size() > 1; if (multiple_disjuncts) @@ -742,10 +743,10 @@ bool HashJoin::addJoinedBlock(const Block & source_block, bool check_limits) BlockWithFlags structured_block = structureRightBlock(block); bool multiple_disjuncts = disjuncts_num > 1; - // if (nullable_right_side && multiple_disjuncts) - // { - // JoinCommon::convertColumnsToNullable(structured_block.block); - // } + if (nullable_right_side && multiple_disjuncts) + { + JoinCommon::convertColumnsToNullable(structured_block.block); + } std::vector join_mask_col_vector(disjuncts_num); // std::vector join_mask_vector(disjuncts_num); bool use_join_mask_col = false;