diff --git a/dbms/src/Interpreters/Join.cpp b/dbms/src/Interpreters/Join.cpp index f519361191f..7b2d6eaeb26 100644 --- a/dbms/src/Interpreters/Join.cpp +++ b/dbms/src/Interpreters/Join.cpp @@ -1417,7 +1417,7 @@ BlockInputStreamPtr Join::createStreamWithNonJoinedRows(const Block & result_sam } -bool Join::hasStreamWithNonJoinedRows() +bool Join::hasStreamWithNonJoinedRows() const { if (table_join->strictness() == ASTTableJoin::Strictness::Asof || table_join->strictness() == ASTTableJoin::Strictness::Semi) diff --git a/dbms/src/Interpreters/Join.h b/dbms/src/Interpreters/Join.h index 36c57d4494c..23b6d51ec0b 100644 --- a/dbms/src/Interpreters/Join.h +++ b/dbms/src/Interpreters/Join.h @@ -179,7 +179,7 @@ public: * left_sample_block is passed without account of 'use_nulls' setting (columns will be converted to Nullable inside). */ BlockInputStreamPtr createStreamWithNonJoinedRows(const Block & result_sample_block, UInt64 max_block_size) const override; - bool hasStreamWithNonJoinedRows(); + bool hasStreamWithNonJoinedRows() const override; /// Number of keys in all built JOIN maps. size_t getTotalRowCount() const final;